Package com.espertech.esper.common.internal.epl.subselect

Class SubselectBufferObserver

java.lang.Object

com.espertech.esper.common.internal.epl.subselect.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	Description
SubselectBufferObserver(EventTable[] eventIndex, ExprEvaluatorContext exprEvaluatorContext)	Ctor.

Method Summary

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

SubselectBufferObserver

public SubselectBufferObserver(EventTable[] eventIndex,
 ExprEvaluatorContext exprEvaluatorContext)

Ctor.

Parameters:

eventIndex - index to update

exprEvaluatorContext - agent instance context

Method Details

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