|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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. |
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 |
public java.util.List loadStatements(java.net.URL location) throws MultiStatementException
<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>
location
- URL location of XML documentpublic Statement createStatement(java.lang.String query) throws StatementException
query
- query string to compilepublic Statement createStatement(java.lang.String query, java.lang.String queryId) throws StatementException
query
- query string to compilequeryId
- ID for query unique over this processorpublic EventTypeRepository getEventTypeRepository()
public StatementManager getStatementManager()
public void addDataProvider(DataProvider source)
source
- - data provider.public void addDataProvider(java.lang.String typeName, DataProvider source)
typeName
- - type of data being providedsource
- - data provider.public void setFunctionBeans(java.util.Map beans)
source
- - reference to bean in the form of a map.public void setDelegateClassLoader(java.lang.ClassLoader delegateLoader)
delegateLoader
- public void setTime(long timeInMillis)
public long getTime()
public Processor.ClockType getClockType()
public void setClockType(Processor.ClockType clockType)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |