com.espertech.esper.dataflow.ops
Class EPStatementSource.EmitterUpdateListener

java.lang.Object
  com.espertech.esper.dataflow.ops.EPStatementSource.EmitterUpdateListener

All Implemented Interfaces:

StatementAwareUpdateListener

Enclosing class:

EPStatementSource

public static class EPStatementSource.EmitterUpdateListener
extends java.lang.Object
implements StatementAwareUpdateListener

Constructor Summary

EPStatementSource.EmitterUpdateListener(java.util.Queue<java.lang.Object> queue, boolean submitEventBean)

Method Summary

void	update(EventBean[] newEvents, EventBean[] oldEvents, EPStatement statement, EPServiceProvider epServiceProvider) Notify that new events are available or old events are removed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EPStatementSource.EmitterUpdateListener

public EPStatementSource.EmitterUpdateListener(java.util.Queue<java.lang.Object> queue,
                                               boolean submitEventBean)

Method Detail

update

public void update(EventBean[] newEvents,
                   EventBean[] oldEvents,
                   EPStatement statement,
                   EPServiceProvider epServiceProvider)

Description copied from interface: StatementAwareUpdateListener

Notify that new events are available or old events are removed.

If the call to update contains new (inserted) events, then the first argument will be a non-empty list and the second will be empty. Similarly, if the call is a notification of deleted events, then the first argument will be empty and the second will be non-empty.

Either the newEvents or oldEvents will be non-null. This method won't be called with both arguments being null (unless using output rate limiting or force-output options), but either one could be null. The same is true for zero-length arrays. Either newEvents or oldEvents will be non-empty. If both are non-empty, then the update is a modification notification.

Specified by:

update in interface StatementAwareUpdateListener

Parameters:

newEvents - is any new events. This will be null or empty if the update is for old events only.

oldEvents - is any old events. This will be null or empty if the update is for new events only.

statement - is the statement producing the result

epServiceProvider - is the engine instance that provided the administrative API that created the statement which produces the result