com.espertech.esper.epl.subquery
Class SubselectBufferObserver

java.lang.Object
  com.espertech.esper.epl.subquery.SubselectBufferObserver

All Implemented Interfaces:

BufferObserver

public class SubselectBufferObserver
extends java.lang.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

SubselectBufferObserver(EventTable[] eventIndex)
Ctor.

Method Summary

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)

Ctor.

Parameters:

eventIndex - index to update

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