public class EPDataFlowInstantiationOptions
extends java.lang.Object
implements java.io.Serializable
EPDataFlowService
.Constructor and Description |
---|
EPDataFlowInstantiationOptions() |
Modifier and Type | Method and Description |
---|---|
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.
|
com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped |
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(com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped surrogateEventSender)
Sets the event sender /runtime to use
|
public EPDataFlowOperatorProvider getOperatorProvider()
public EPDataFlowInstantiationOptions operatorProvider(EPDataFlowOperatorProvider operatorProvider)
operatorProvider
- operator providerpublic void setOperatorProvider(EPDataFlowOperatorProvider operatorProvider)
operatorProvider
- operator providerpublic EPDataFlowInstantiationOptions parameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)
parameterProvider
- parameter providerpublic EPDataFlowOperatorParameterProvider getParameterProvider()
public void setParameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)
parameterProvider
- parameter providerpublic EPDataFlowExceptionHandler getExceptionHandler()
public EPDataFlowInstantiationOptions exceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
exceptionHandler
- exception handler.public void setExceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
exceptionHandler
- exception handler.public java.lang.String getDataFlowInstanceId()
public EPDataFlowInstantiationOptions dataFlowInstanceId(java.lang.String dataFlowInstanceId)
dataFlowInstanceId
- instance idpublic void setDataFlowInstanceId(java.lang.String dataFlowInstanceId)
dataFlowInstanceId
- instance idpublic java.lang.Object getDataFlowInstanceUserObject()
public EPDataFlowInstantiationOptions dataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject)
dataFlowInstanceUserObject
- user objectpublic void setDataFlowInstanceUserObject(java.lang.Object dataFlowInstanceUserObject)
dataFlowInstanceUserObject
- this options objectpublic boolean isOperatorStatistics()
public EPDataFlowInstantiationOptions operatorStatistics(boolean statistics)
statistics
- operator stats indicatorpublic void setOperatorStatistics(boolean operatorStatistics)
operatorStatistics
- operator stats indicatorpublic boolean isCpuStatistics()
public void setCpuStatistics(boolean cpuStatistics)
cpuStatistics
- CPU statspublic EPDataFlowInstantiationOptions cpuStatistics(boolean cpuStatistics)
cpuStatistics
- CPU statspublic com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped getSurrogateEventSender()
public void setSurrogateEventSender(com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped surrogateEventSender)
surrogateEventSender
- runtime to use for sendingpublic void addParameterURI(java.lang.String name, java.lang.Object value)
name
- is the urivalue
- the valuepublic java.util.Map<java.lang.String,java.lang.Object> getParametersURIs()
public void setParametersURIs(java.util.Map<java.lang.String,java.lang.Object> parametersURIs)
parametersURIs
- map of name value pairs