com.espertech.esper.epl.subquery

Class SubselectBufferObserver

java.lang.Object

com.espertech.esper.epl.subquery.SubselectBufferObserver

All Implemented Interfaces:

BufferObserver

public class SubselectBufferObserver
extends Object
implements BufferObserver

Observer to a buffer that is filled by a subselect view when it posts events, to be added and removed from indexes.

Constructor Summary

Constructors

Constructor and Description
SubselectBufferObserver(EventTable[] eventIndex, AgentInstanceContext agentInstanceContext) Ctor.

Method Summary

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

SubselectBufferObserver

public SubselectBufferObserver(EventTable[] eventIndex,
                               AgentInstanceContext agentInstanceContext)

Ctor.

Parameters:

eventIndex - index to update

agentInstanceContext - agent instance context

Method Detail

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