Package com.espertech.esper.common.internal.epl.dataflow.core

Class EPDataFlowInstanceImpl

java.lang.Object

com.espertech.esper.common.internal.epl.dataflow.core.EPDataFlowInstanceImpl

All Implemented Interfaces:

EPDataFlowInstance

public class EPDataFlowInstanceImpl
extends Object
implements EPDataFlowInstance

Constructor Summary

Constructors

Constructor	Description
EPDataFlowInstanceImpl(Object dataFlowInstanceUserObject, String dataFlowInstanceId, OperatorStatisticsProvider statistics, Map<Integer,Object> operators, List<GraphSourceRunnable> sourceRunnables, DataflowDesc dataflowDesc, AgentInstanceContext agentInstanceContext, EPDataFlowInstanceStatistics statisticsProvider, Map<String,Object> parametersURIs)

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancel execution.
void	completed()
String	getDataFlowDeploymentId()	Returns the data flow deployment id.
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 Details

EPDataFlowInstanceImpl

public EPDataFlowInstanceImpl(Object dataFlowInstanceUserObject,
 String dataFlowInstanceId,
 OperatorStatisticsProvider statistics,
 Map<Integer,Object> operators,
 List<GraphSourceRunnable> sourceRunnables,
 DataflowDesc dataflowDesc,
 AgentInstanceContext agentInstanceContext,
 EPDataFlowInstanceStatistics statisticsProvider,
 Map<String,Object> parametersURIs)

Method Details

getDataFlowName

public String getDataFlowName()

Description copied from interface: EPDataFlowInstance

Returns the data flow name.

Specified by:

getDataFlowName in interface EPDataFlowInstance

Returns:

name

getDataFlowDeploymentId

public String getDataFlowDeploymentId()

Description copied from interface: EPDataFlowInstance

Returns the data flow deployment id.

Specified by:

getDataFlowDeploymentId in interface EPDataFlowInstance

Returns:

deployment id

getState

public EPDataFlowState getState()

Description copied from interface: EPDataFlowInstance

Returns the state.

Specified by:

getState in interface EPDataFlowInstance

Returns:

state

run

public void run()
         throws IllegalStateException,
EPDataFlowExecutionException,
EPDataFlowCancellationException

Description copied from interface: EPDataFlowInstance

Blocking execution of the data flow instance.

Specified by:

run in interface EPDataFlowInstance

Throws:

IllegalStateException - thrown to indicate that the state is not instantiated.

EPDataFlowExecutionException - thrown when an execution exception occurs

EPDataFlowCancellationException - throw to indicate the data flow was cancelled.

start

public void start()
           throws IllegalStateException

Description copied from interface: EPDataFlowInstance

Non-Blocking execution of the data flow instance.

Specified by:

start in interface EPDataFlowInstance

Throws:

IllegalStateException - thrown to indicate that the state is not instantiated.

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

join

public void join()
          throws IllegalStateException,
InterruptedException

Description copied from interface: EPDataFlowInstance

Join an executing data flow instance.

Specified by:

join in interface EPDataFlowInstance

Throws:

IllegalStateException - thrown if it cannot be joined

InterruptedException - thrown if interrupted

cancel

public void cancel()

Description copied from interface: EPDataFlowInstance

Cancel execution.

Specified by:

cancel in interface EPDataFlowInstance

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

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

completed

public void completed()