com.espertech.esper.epl.join.base

Class JoinExecStrategyDispatchable

java.lang.Object

com.espertech.esper.epl.join.base.JoinExecStrategyDispatchable

All Implemented Interfaces:

EPStatementDispatch, BufferObserver

public class JoinExecStrategyDispatchable
extends Object
implements EPStatementDispatch, 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

Constructors

Constructor and Description
JoinExecStrategyDispatchable(JoinExecutionStrategy joinExecutionStrategy, int numStreams) CTor.

Method Summary

Modifier and Type	Method and Description
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(JoinExecutionStrategy joinExecutionStrategy,
                                    int numStreams)

CTor.

Parameters:

joinExecutionStrategy - - strategy for executing the join

numStreams - - number of stream

Method Detail

execute

public void execute()

Description copied from interface: EPStatementDispatch

Execute dispatch.

Specified by:

execute in interface EPStatementDispatch

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