Package com.espertech.esper.common.internal.epl.join.base

Class JoinExecStrategyDispatchable

java.lang.Object

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

All Implemented Interfaces:

EPStatementDispatch, BufferObserver

public class JoinExecStrategyDispatchable
extends Object
implements BufferObserver, EPStatementDispatch

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	Description
JoinExecStrategyDispatchable(JoinExecutionStrategy joinExecutionStrategy, int numStreams, AgentInstanceContext agentInstanceContext)

Method Summary

Modifier and Type	Method	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 Details

JoinExecStrategyDispatchable

public JoinExecStrategyDispatchable(JoinExecutionStrategy joinExecutionStrategy,
 int numStreams,
 AgentInstanceContext agentInstanceContext)

Method Details

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