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

Interface EPDataFlowInstance

public interface EPDataFlowInstance

Data flow instanve.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancel execution.
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.

Method Details

getDataFlowDeploymentId

String getDataFlowDeploymentId()

Returns the data flow deployment id.

Returns:

deployment id

getDataFlowName

String getDataFlowName()

Returns the data flow name.

Returns:

name

getState

EPDataFlowState getState()

Returns the state.

Returns:

state

run

void run()
  throws IllegalStateException,
EPDataFlowExecutionException,
EPDataFlowCancellationException

Blocking execution of the data flow instance.

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

void start()
    throws IllegalStateException

Non-Blocking execution of the data flow instance.

Throws:

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

startCaptive

EPDataFlowInstanceCaptive startCaptive()

Captive execution of the data flow instance.

Returns:

runnables and emitters

join

void join()
   throws IllegalStateException,
InterruptedException

Join an executing data flow instance.

Throws:

IllegalStateException - thrown if it cannot be joined

InterruptedException - thrown if interrupted

cancel

void cancel()

Cancel execution.

getStatistics

EPDataFlowInstanceStatistics getStatistics()

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

Returns:

stats

getUserObject

Object getUserObject()

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

Returns:

user object

getInstanceId

String getInstanceId()

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

Returns:

instance if

getParameters

Map<String,Object> getParameters()

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

Returns:

runtime parameters