com.espertech.esper.dataflow.ops
Class EPStatementSource.EmitterCollectorUpdateListener
java.lang.Object
com.espertech.esper.dataflow.ops.EPStatementSource.EmitterCollectorUpdateListener
- All Implemented Interfaces:
- StatementAwareUpdateListener
- Enclosing class:
- EPStatementSource
public static class EPStatementSource.EmitterCollectorUpdateListener
- extends java.lang.Object
- implements StatementAwareUpdateListener
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EPStatementSource.EmitterCollectorUpdateListener
public EPStatementSource.EmitterCollectorUpdateListener(EPDataFlowIRStreamCollector collector,
EPStatementSource.LocalEmitter emitterForCollector,
java.lang.ThreadLocal<EPDataFlowIRStreamCollectorContext> collectorDataTL,
boolean submitEventBean)
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 resultepServiceProvider
- is the engine instance that provided the administrative API that created the statement which produces the result