|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.join.JoinExecStrategyDispatchable
public class JoinExecStrategyDispatchable
This class reacts to any new data buffered by registring with the dispatch service. When dispatched via execute, it takes the buffered events and hands these to the join execution strategy.
Constructor Summary | |
---|---|
JoinExecStrategyDispatchable(DispatchService dispatchService,
JoinExecutionStrategy joinExecutionStrategy,
int numStreams)
CTor. |
Method Summary | |
---|---|
void |
execute()
Execute dispatch. |
void |
newData(int streamId,
FlushedEventBuffer newEventBuffer,
FlushedEventBuffer oldEventBuffer)
Receive new and old events from a stream. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JoinExecStrategyDispatchable(DispatchService dispatchService, JoinExecutionStrategy joinExecutionStrategy, int numStreams)
dispatchService
- - dispatches to this object via execute methodjoinExecutionStrategy
- - strategy for executing the joinnumStreams
- - number of streamMethod Detail |
---|
public void execute()
Dispatchable
execute
in interface Dispatchable
public void newData(int streamId, FlushedEventBuffer newEventBuffer, FlushedEventBuffer oldEventBuffer)
BufferObserver
newData
in interface BufferObserver
streamId
- - the stream number sending the eventsnewEventBuffer
- - buffer for new eventsoldEventBuffer
- - buffer for old events
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |