Package com.espertech.esper.common.client.dataflow.core

Class EPDataFlowIRStreamCollectorContext

java.lang.Object

com.espertech.esper.common.client.dataflow.core.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	Description
EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter, boolean submitEventBean, EventBean[] newEvents, EventBean[] oldEvents, Object statement, Object runtime)	Ctor.

Method Summary

Modifier and Type	Method	Description
EPDataFlowEmitter	getEmitter()	Returns the emitter.
EventBean[]	getNewEvents()	Returns insert stream.
EventBean[]	getOldEvents()	Returns remove stream.
Object	getRuntime()	Returns the runtime instance and can safely be cast to runtime when needed(typed object to not require a dependency on runtime)
Object	getStatement()	Returns the statement and can safely be cast to EPStatement when needed(typed object to not require a dependency on runtime)
boolean	isSubmitEventBean()	Returns indicator whether to submit wrapped events (EventBean) or underlying events

Methods inherited from class java.lang.Object

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

Constructor Details

EPDataFlowIRStreamCollectorContext

public EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter,
 boolean submitEventBean,
 EventBean[] newEvents,
 EventBean[] oldEvents,
 Object statement,
 Object runtime)

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

runtime - runtime instance

Method Details

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 Object getStatement()

Returns the statement and can safely be cast to EPStatement when needed(typed object to not require a dependency on runtime)

Returns:

statement

getRuntime

public Object getRuntime()

Returns the runtime instance and can safely be cast to runtime when needed(typed object to not require a dependency on runtime)

Returns:

runtime instance

isSubmitEventBean

public boolean isSubmitEventBean()

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

Returns:

wrapped event indicator