Skip navigation links

com.bea.wlevs.ede.api
Interface Processor

public interface Processor

extends Stage, EventSink

Processors filter, correlate, aggregate, and perform other event processing functions. These functions are specified in some high-level language other than Java, as determined by the returned URI.

Inner Class Summary

static class

Processor.ClockType

Method Summary
void	addDataProvider(DataProvider source) In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.
void	addDataProvider(java.lang.String typeName, DataProvider source) In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.
void	addExternalSource(ExternalSource source) In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.
Statement	createStatement(java.lang.String query) Compile query using the supplied query string parameter.
Statement	createStatement(java.lang.String query, java.lang.String queryId) Compile query using the supplied query string parameter and query id.
Processor.ClockType	getClockType()
EventTypeRepository	getEventTypeRepository() Returns repository for types defined within the application.
StatementManager	getStatementManager() Returns statement manager for accessing compiled statements defined for this processor.
long	getTime()
java.util.List	loadStatements(java.net.URL location) Load queries from an XML document located at the specified URL.
void	setClockType(Processor.ClockType clockType)
void	setDelegateClassLoader(java.lang.ClassLoader delegateLoader) Sets the ClassLoader to use to resolve user defined functions.
void	setFunctionBeans(java.util.Map beans) Sets map of beans containing user-defined functions for this processor.
void	setTime(long timeInMillis)

Methods inherited from interface com.bea.wlevs.ede.api.EventSink

onEvent

Method Detail

loadStatements

public java.util.List loadStatements(java.net.URL location)
                              throws MultiStatementException

Load queries from an XML document located at the specified URL. Parameterized queries and their associated parameter value bindings may optionally be included as well. The XML document may be the entire processor configuration file or a subset containing the rules element and optionally the bindings element as shown below:

    <processor
       <rules>
          <rule id="rule1"><![CDATA[
             select stockSymbol, perc(price) as percentage
             from StockTick retain 10 events
             where stockSymbol='ACME'
             having perc(price) > 10.0 or perc(price) < -10.0
          ]]></rule>
          <rule id="rule2"><![CDATA[
             select stockSymbol, perc(price) as percentage
             from StockTick retain 10 events
             where stockSymbol=?
             having perc(price) > ? or perc(price) < ?
          ]]></rule>
       </rules>
       <bindings>
          <binding>
             <params>ORCL,5.0,-5.0</params>
             <params>BEAS,10.0,-10.0</params>
          </binding>
       </bindings>
    </processor>
 

Parameters:

location - URL location of XML document

Throws:

MultiStatementException - aggregation of any exceptions that occur during query compilation.

createStatement

public Statement createStatement(java.lang.String query)
                          throws StatementException

Compile query using the supplied query string parameter. A query id will be generated in this case.

Parameters:

query - query string to compile

Throws:

StatementException - if exception occurs during query compilation.

createStatement

public Statement createStatement(java.lang.String query,
                                 java.lang.String queryId)
                          throws StatementException

Compile query using the supplied query string parameter and query id. The query id must be unique for this processor.

Parameters:

query - query string to compile

queryId - ID for query unique over this processor

Throws:

StatementException - if exception occurs during query compilation.

getEventTypeRepository

public EventTypeRepository getEventTypeRepository()

Returns repository for types defined within the application.

Returns:

EventTypeRepository for types defined within the application.

getStatementManager

public StatementManager getStatementManager()

Returns statement manager for accessing compiled statements defined for this processor.

Returns:

StatementManager for accessing compiled statements defined for this processor.

addDataProvider

public void addDataProvider(DataProvider source)

In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.

Parameters:

source - - data provider.

addDataProvider

public void addDataProvider(java.lang.String typeName,
                            DataProvider source)

In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.

Parameters:

typeName - - type of data being provided

source - - data provider.

addExternalSource

public void addExternalSource(ExternalSource source)

In addition to receiving and sending events, a processor can poll data providers to be able to merge the streaming events with static data.

Parameters:

source -

setFunctionBeans

public void setFunctionBeans(java.util.Map beans)

Sets map of beans containing user-defined functions for this processor.

Parameters:

source - - reference to bean in the form of a map.

setDelegateClassLoader

public void setDelegateClassLoader(java.lang.ClassLoader delegateLoader)

Sets the ClassLoader to use to resolve user defined functions.

Parameters:

delegateLoader -

setTime

public void setTime(long timeInMillis)

getTime

public long getTime()

getClockType

public Processor.ClockType getClockType()

setClockType

public void setClockType(Processor.ClockType clockType)