com.espertech.esper.client.dataflow
Class EPDataFlowInstantiationOptions

java.lang.Object
  com.espertech.esper.client.dataflow.EPDataFlowInstantiationOptions

All Implemented Interfaces:

java.io.Serializable

public class EPDataFlowInstantiationOptions
extends java.lang.Object
implements java.io.Serializable

Options for use when instantiating a data flow in EPDataFlowRuntime.

See Also:

Serialized Form

Constructor Summary

EPDataFlowInstantiationOptions()

Method Summary

void	addParameterURI(java.lang.String name, java.lang.Object value) Add a parameter.
EPDataFlowInstantiationOptions	cpuStatistics(boolean cpuStatistics) Sets indicator whether to collect CPU statistics.
EPDataFlowInstantiationOptions	dataFlowInstanceId(java.lang.String dataFlowInstanceId) Sets the data flow instance id
EPDataFlowInstantiationOptions	dataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject) Sets the user object associated to the data flow instance.
EPDataFlowInstantiationOptions	exceptionHandler(EPDataFlowExceptionHandler exceptionHandler) Sets the exception handler.
java.lang.String	getDataFlowInstanceId() Returns the instance id assigned.
java.lang.Object	getDataFlowInstanceUserObject() Returns the user object associated to the data flow instance.
EPDataFlowExceptionHandler	getExceptionHandler() Returns the exception handler.
EPDataFlowOperatorProvider	getOperatorProvider() Returns the operator provider.
EPDataFlowOperatorParameterProvider	getParameterProvider() Returns the parameter provider.
java.util.Map<java.lang.String,java.lang.Object>	getParametersURIs() Returns parameters.
EPRuntimeEventSender	getSurrogateEventSender() Returns the event sender /runtime to use
boolean	isCpuStatistics() Returns indicator whether to collect CPU statistics.
boolean	isOperatorStatistics() Returns indicator whether to collect operator statistics.
EPDataFlowInstantiationOptions	operatorProvider(EPDataFlowOperatorProvider operatorProvider) Sets the the operator provider.
EPDataFlowInstantiationOptions	operatorStatistics(boolean statistics) Sets indicator whether to collect operator statistics.
EPDataFlowInstantiationOptions	parameterProvider(EPDataFlowOperatorParameterProvider parameterProvider) Sets the parameter provider.
void	setCpuStatistics(boolean cpuStatistics) Sets indicator whether to collect CPU statistics.
void	setDataFlowInstanceId(java.lang.String dataFlowInstanceId) Sets the data flow instance id
void	setDataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject) Sets the user object associated to the data flow instance.
void	setExceptionHandler(EPDataFlowExceptionHandler exceptionHandler) Sets the exception handler.
void	setOperatorProvider(EPDataFlowOperatorProvider operatorProvider) Sets the the operator provider.
void	setOperatorStatistics(boolean operatorStatistics) Sets indicator whether to collect operator statistics.
void	setParameterProvider(EPDataFlowOperatorParameterProvider parameterProvider) Sets the parameter provider.
void	setParametersURIs(java.util.Map<java.lang.String,java.lang.Object> parametersURIs) Sets parameters.
void	setSurrogateEventSender(EPRuntimeEventSender surrogateEventSender) Sets the event sender /runtime to use

Methods inherited from class java.lang.Object

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

Constructor Detail

EPDataFlowInstantiationOptions

public EPDataFlowInstantiationOptions()

Method Detail

getOperatorProvider

public EPDataFlowOperatorProvider getOperatorProvider()

Returns the operator provider.

Returns:

operator provider

operatorProvider

public EPDataFlowInstantiationOptions operatorProvider(EPDataFlowOperatorProvider operatorProvider)

Sets the the operator provider.

Parameters:

operatorProvider - operator provider

Returns:

this options object

setOperatorProvider

public void setOperatorProvider(EPDataFlowOperatorProvider operatorProvider)

Sets the the operator provider.

Parameters:

operatorProvider - operator provider

parameterProvider

public EPDataFlowInstantiationOptions parameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)

Sets the parameter provider.

Parameters:

parameterProvider - parameter provider

Returns:

this options object

getParameterProvider

public EPDataFlowOperatorParameterProvider getParameterProvider()

Returns the parameter provider.

Returns:

parameter provider

setParameterProvider

public void setParameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)

Sets the parameter provider.

Parameters:

parameterProvider - parameter provider

getExceptionHandler

public EPDataFlowExceptionHandler getExceptionHandler()

Returns the exception handler.

Returns:

exception handler.

exceptionHandler

public EPDataFlowInstantiationOptions exceptionHandler(EPDataFlowExceptionHandler exceptionHandler)

Sets the exception handler.

Parameters:

exceptionHandler - exception handler.

Returns:

this options object

setExceptionHandler

public void setExceptionHandler(EPDataFlowExceptionHandler exceptionHandler)

Sets the exception handler.

Parameters:

exceptionHandler - exception handler.

getDataFlowInstanceId

public java.lang.String getDataFlowInstanceId()

Returns the instance id assigned.

Returns:

instance if

dataFlowInstanceId

public EPDataFlowInstantiationOptions dataFlowInstanceId(java.lang.String dataFlowInstanceId)

Sets the data flow instance id

Parameters:

dataFlowInstanceId - instance id

Returns:

this options object

setDataFlowInstanceId

public void setDataFlowInstanceId(java.lang.String dataFlowInstanceId)

Sets the data flow instance id

Parameters:

dataFlowInstanceId - instance id

getDataFlowInstanceUserObject

public java.lang.Object getDataFlowInstanceUserObject()

Returns the user object associated to the data flow instance.

Returns:

user object

dataFlowInstanceUserObject

public EPDataFlowInstantiationOptions dataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject)

Sets the user object associated to the data flow instance.

Parameters:

dataFlowInstanceUserObject - user object

Returns:

this options object

setDataFlowInstanceUserObject

public void setDataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject)

Sets the user object associated to the data flow instance.

Parameters:

dataFlowInstanceUserObject - this options object

isOperatorStatistics

public boolean isOperatorStatistics()

Returns indicator whether to collect operator statistics.

Returns:

operator stats indicator

operatorStatistics

public EPDataFlowInstantiationOptions operatorStatistics(boolean statistics)

Sets indicator whether to collect operator statistics.

Parameters:

statistics - operator stats indicator

Returns:

this options object

setOperatorStatistics

public void setOperatorStatistics(boolean operatorStatistics)

Sets indicator whether to collect operator statistics.

Parameters:

operatorStatistics - operator stats indicator

isCpuStatistics

public boolean isCpuStatistics()

Returns indicator whether to collect CPU statistics.

Returns:

CPU stats

setCpuStatistics

public void setCpuStatistics(boolean cpuStatistics)

Sets indicator whether to collect CPU statistics.

Parameters:

cpuStatistics - CPU stats

cpuStatistics

public EPDataFlowInstantiationOptions cpuStatistics(boolean cpuStatistics)

Sets indicator whether to collect CPU statistics.

Parameters:

cpuStatistics - CPU stats

Returns:

this options object

getSurrogateEventSender

public EPRuntimeEventSender getSurrogateEventSender()

Returns the event sender /runtime to use

Returns:

runtime.

setSurrogateEventSender

public void setSurrogateEventSender(EPRuntimeEventSender surrogateEventSender)

Sets the event sender /runtime to use

Parameters:

surrogateEventSender - runtime to use for sending

addParameterURI

public void addParameterURI(java.lang.String name,
                            java.lang.Object value)

Add a parameter.

Parameters:

name - is the uri

value - the value

getParametersURIs

public java.util.Map<java.lang.String,java.lang.Object> getParametersURIs()

Returns parameters.

Returns:

parameters

setParametersURIs

public void setParametersURIs(java.util.Map<java.lang.String,java.lang.Object> parametersURIs)

Sets parameters.

Parameters:

parametersURIs - map of name value pairs