net.esper.eql.join
Class JoinExecStrategyDispatchable

java.lang.Object
  extended by net.esper.eql.join.JoinExecStrategyDispatchable
All Implemented Interfaces:
Dispatchable, BufferObserver

public class JoinExecStrategyDispatchable
extends Object
implements Dispatchable, BufferObserver

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

JoinExecStrategyDispatchable

public JoinExecStrategyDispatchable(DispatchService dispatchService,
                                    JoinExecutionStrategy joinExecutionStrategy,
                                    int numStreams)
CTor.

Parameters:
dispatchService - - dispatches to this object via execute method
joinExecutionStrategy - - strategy for executing the join
numStreams - - number of stream
Method Detail

execute

public void execute()
Description copied from interface: Dispatchable
Execute dispatch.

Specified by:
execute in interface Dispatchable

newData

public void newData(int streamId,
                    FlushedEventBuffer newEventBuffer,
                    FlushedEventBuffer oldEventBuffer)
Description copied from interface: BufferObserver
Receive new and old events from a stream.

Specified by:
newData in interface BufferObserver
Parameters:
streamId - - the stream number sending the events
newEventBuffer - - buffer for new events
oldEventBuffer - - buffer for old events