public class EPDataFlowInstantiationOptions extends Object implements Serializable
EPDataFlowRuntime
.Constructor and Description |
---|
EPDataFlowInstantiationOptions() |
Modifier and Type | Method and Description |
---|---|
void |
addParameterURI(String name,
Object value)
Add a parameter.
|
EPDataFlowInstantiationOptions |
cpuStatistics(boolean cpuStatistics)
Sets indicator whether to collect CPU statistics.
|
EPDataFlowInstantiationOptions |
dataFlowInstanceId(String dataFlowInstanceId)
Sets the data flow instance id
|
EPDataFlowInstantiationOptions |
dataFlowInstanceUserObject(Object dataFlowInstanceUserObject)
Sets the user object associated to the data flow instance.
|
EPDataFlowInstantiationOptions |
exceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
Sets the exception handler.
|
String |
getDataFlowInstanceId()
Returns the instance id assigned.
|
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.
|
Map<String,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(String dataFlowInstanceId)
Sets the data flow instance id
|
void |
setDataFlowInstanceUserObject(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(Map<String,Object> parametersURIs)
Sets parameters.
|
void |
setSurrogateEventSender(EPRuntimeEventSender 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 String getDataFlowInstanceId()
public EPDataFlowInstantiationOptions dataFlowInstanceId(String dataFlowInstanceId)
dataFlowInstanceId
- instance idpublic void setDataFlowInstanceId(String dataFlowInstanceId)
dataFlowInstanceId
- instance idpublic Object getDataFlowInstanceUserObject()
public EPDataFlowInstantiationOptions dataFlowInstanceUserObject(Object dataFlowInstanceUserObject)
dataFlowInstanceUserObject
- user objectpublic void setDataFlowInstanceUserObject(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 EPRuntimeEventSender getSurrogateEventSender()
public void setSurrogateEventSender(EPRuntimeEventSender surrogateEventSender)
surrogateEventSender
- runtime to use for sendingpublic void addParameterURI(String name, Object value)
name
- is the urivalue
- the valuepublic Map<String,Object> getParametersURIs()