com.espertech.esper.dataflow.core

Class EPDataFlowInstanceImpl

java.lang.Object

com.espertech.esper.dataflow.core.EPDataFlowInstanceImpl

All Implemented Interfaces:

EPDataFlowInstance, CompletionListener

public class EPDataFlowInstanceImpl
extends Object
implements EPDataFlowInstance, CompletionListener

Constructor Summary

Constructors

Constructor and Description
EPDataFlowInstanceImpl(String engineURI, String statementName, boolean audit, String dataFlowName, Object userObject, String instanceId, EPDataFlowState state, List<GraphSourceRunnable> sourceRunnables, Map<Integer,Object> operators, Set<Integer> operatorBuildOrder, EPDataFlowInstanceStatistics statisticsProvider, Map<String,Object> parameters, EngineImportService engineImportService)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel execution.
void	completed()
String	getDataFlowName() Returns the data flow name.
String	getInstanceId() Returns the instance id associated, if any.
Map<String,Object>	getParameters() Returns runtime parameters provided at instantiation time, or null if none have been provided.
EPDataFlowState	getState() Returns the state.
EPDataFlowInstanceStatistics	getStatistics() Get data flow instance statistics, required instantiation with statistics option, use EPDataFlowInstantiationOptions to turn on stats.
Object	getUserObject() Returns the user object associated, if any.
void	join() Join an executing data flow instance.
void	run() Blocking execution of the data flow instance.
void	start() Non-Blocking execution of the data flow instance.
EPDataFlowInstanceCaptive	startCaptive() Captive execution of the data flow instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

EPDataFlowInstanceImpl

public EPDataFlowInstanceImpl(String engineURI,
                              String statementName,
                              boolean audit,
                              String dataFlowName,
                              Object userObject,
                              String instanceId,
                              EPDataFlowState state,
                              List<GraphSourceRunnable> sourceRunnables,
                              Map<Integer,Object> operators,
                              Set<Integer> operatorBuildOrder,
                              EPDataFlowInstanceStatistics statisticsProvider,
                              Map<String,Object> parameters,
                              EngineImportService engineImportService)

Method Detail

getDataFlowName

public String getDataFlowName()

Description copied from interface: EPDataFlowInstance

Returns the data flow name.

Specified by:

getDataFlowName in interface EPDataFlowInstance

Returns:

name

getState

public EPDataFlowState getState()

Description copied from interface: EPDataFlowInstance

Returns the state.

Specified by:

getState in interface EPDataFlowInstance

Returns:

state

getUserObject

public Object getUserObject()

Description copied from interface: EPDataFlowInstance

Returns the user object associated, if any. Use EPDataFlowInstantiationOptions to associate.

Specified by:

getUserObject in interface EPDataFlowInstance

Returns:

user object

getInstanceId

public String getInstanceId()

Description copied from interface: EPDataFlowInstance

Returns the instance id associated, if any. Use EPDataFlowInstantiationOptions to associate.

Specified by:

getInstanceId in interface EPDataFlowInstance

Returns:

instance if

getParameters

public Map<String,Object> getParameters()

Description copied from interface: EPDataFlowInstance

Returns runtime parameters provided at instantiation time, or null if none have been provided.

Specified by:

getParameters in interface EPDataFlowInstance

Returns:

runtime parameters

startCaptive

public EPDataFlowInstanceCaptive startCaptive()

Description copied from interface: EPDataFlowInstance

Captive execution of the data flow instance.

Specified by:

startCaptive in interface EPDataFlowInstance

Returns:

runnables and emitters

run

public void run()

Description copied from interface: EPDataFlowInstance

Blocking execution of the data flow instance.

Specified by:

run in interface EPDataFlowInstance

start

public void start()

Description copied from interface: EPDataFlowInstance

Non-Blocking execution of the data flow instance.

Specified by:

start in interface EPDataFlowInstance

join

public void join()
          throws InterruptedException

Description copied from interface: EPDataFlowInstance

Join an executing data flow instance.

Specified by:

join in interface EPDataFlowInstance

Throws:

InterruptedException - thrown if interrupted

cancel

public void cancel()

Description copied from interface: EPDataFlowInstance

Cancel execution.

Specified by:

cancel in interface EPDataFlowInstance

completed

public void completed()

Specified by:

completed in interface CompletionListener

getStatistics

public EPDataFlowInstanceStatistics getStatistics()

Description copied from interface: EPDataFlowInstance

Get data flow instance statistics, required instantiation with statistics option, use EPDataFlowInstantiationOptions to turn on stats.

Specified by:

getStatistics in interface EPDataFlowInstance

Returns:

stats