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
abstract 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.
abstract void	addDataProvider(java.lang.String typeName, DataProvider source) Deprecated. see addExternalSource
abstract 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.
abstract Statement	createStatement(java.lang.String query) Compile query using the supplied query string parameter.
abstract Statement	createStatement(java.lang.String query, java.lang.String queryId) Compile query using the supplied query string parameter and query id.
abstract boolean	destroyStatement(java.lang.String statementId) Deletes statement and removes it from processor.
abstract Processor.ClockType	getClockType()
abstract EventTypeRepository	getEventTypeRepository() Returns repository for types defined within the application.
abstract StatementManager	getStatementManager() Returns statement manager for accessing compiled statements defined for this processor.
abstract long	getTime()
abstract java.util.List	loadStatements(java.net.URL location) Load queries from an XML document located at the specified URL.
abstract void	setClockType(Processor.ClockType clockType)
abstract void	setDelegateClassLoader(java.lang.ClassLoader delegateLoader) Sets the ClassLoader to use to resolve user defined functions.
abstract void	setFunctionBeans(java.util.Map beans) Sets map of beans containing user-defined functions for this processor.
abstract 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.

destroyStatement

public boolean destroyStatement(java.lang.String statementId)

Deletes statement and removes it from processor. Returns true if statement was found and removed, and false otherwise.

Parameters:

statement - id of existing statement.

Boolean - true if removed, and false otherwise.

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)

Deprecated. see addExternalSource

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)