com.espertech.esper.client.dataflow

Class EPDataFlowIRStreamCollectorContext

java.lang.Object

com.espertech.esper.client.dataflow.EPDataFlowIRStreamCollectorContext

public class EPDataFlowIRStreamCollectorContext
extends Object

Context for use with EPDataFlowIRStreamCollector.

Do not retain a handle of this object as its contents are subject to change.

Constructor Summary

Constructors

Constructor and Description
EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter, boolean submitEventBean, EventBean[] newEvents, EventBean[] oldEvents, EPStatement statement, EPServiceProvider epServiceProvider) Ctor.

Method Summary

Modifier and Type	Method and Description
EPDataFlowEmitter	getEmitter() Returns the emitter.
EPServiceProvider	getEpServiceProvider() Returns the engine instance.
EventBean[]	getNewEvents() Returns insert stream.
EventBean[]	getOldEvents() Returns remove stream.
EPStatement	getStatement() Returns the statement.
boolean	isSubmitEventBean() Returns indicator whether to submit wrapped events (EventBean) or underlying events
void	setEpServiceProvider(EPServiceProvider epServiceProvider) Sets engine instance.
void	setNewEvents(EventBean[] newEvents) Sets insert stream events
void	setOldEvents(EventBean[] oldEvents) Sets remove stream events
void	setStatement(EPStatement statement) Sets statement.

Methods inherited from class java.lang.Object

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

Constructor Detail

EPDataFlowIRStreamCollectorContext

public EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter,
                                          boolean submitEventBean,
                                          EventBean[] newEvents,
                                          EventBean[] oldEvents,
                                          EPStatement statement,
                                          EPServiceProvider epServiceProvider)

Ctor.

Parameters:

emitter - data flow emitter

submitEventBean - indicator whether the EventBean or the underlying event object must be submmitted

newEvents - insert stream events

oldEvents - remove stream events

statement - statement posting events

epServiceProvider - engine instances

Method Detail

getEmitter

public EPDataFlowEmitter getEmitter()

Returns the emitter.

Returns:

emitter

getNewEvents

public EventBean[] getNewEvents()

Returns insert stream.

Returns:

events

getOldEvents

public EventBean[] getOldEvents()

Returns remove stream.

Returns:

events

getStatement

public EPStatement getStatement()

Returns the statement.

Returns:

statement

getEpServiceProvider

public EPServiceProvider getEpServiceProvider()

Returns the engine instance.

Returns:

engine instance

setNewEvents

public void setNewEvents(EventBean[] newEvents)

Sets insert stream events

Parameters:

newEvents - to set

setOldEvents

public void setOldEvents(EventBean[] oldEvents)

Sets remove stream events

Parameters:

oldEvents - to set

setStatement

public void setStatement(EPStatement statement)

Sets statement.

Parameters:

statement - to set

setEpServiceProvider

public void setEpServiceProvider(EPServiceProvider epServiceProvider)

Sets engine instance.

Parameters:

epServiceProvider - to set

isSubmitEventBean

public boolean isSubmitEventBean()

Returns indicator whether to submit wrapped events (EventBean) or underlying events

Returns:

wrapped event indicator