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

Class EPDataFlowInstanceCaptive

java.lang.Object

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

public class EPDataFlowInstanceCaptive
extends Object

Holder for captive data flow execution.

Constructor Summary

Constructors

Constructor	Description
EPDataFlowInstanceCaptive(Map<String,EPDataFlowEmitterOperator> emitters, List<GraphSourceRunnable> runnables)	Ctor.

Method Summary

Modifier and Type	Method	Description
Map<String,EPDataFlowEmitterOperator>	getEmitters()	Map of named emitters.
List<GraphSourceRunnable>	getRunnables()	List of operator source runnables.

Methods inherited from class java.lang.Object

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

Constructor Details

EPDataFlowInstanceCaptive

public EPDataFlowInstanceCaptive(Map<String,EPDataFlowEmitterOperator> emitters,
 List<GraphSourceRunnable> runnables)

Ctor.

Parameters:

emitters - any emitters that are part of the data flow

runnables - any runnables that represent source operators

Method Details

getEmitters

public Map<String,EPDataFlowEmitterOperator> getEmitters()

Map of named emitters.

Returns:

emitters

getRunnables

public List<GraphSourceRunnable> getRunnables()

List of operator source runnables.

Returns:

runnables