Package | Description |
---|---|
com.espertech.esper.common.client.dataflow.core |
Client API for data flows.
|
com.espertech.esper.common.internal.epl.dataflow.core | |
com.espertech.esper.common.internal.epl.dataflow.realize |
Modifier and Type | Method and Description |
---|---|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.cpuStatistics(boolean cpuStatistics)
Sets indicator whether to collect CPU statistics.
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.dataFlowInstanceId(String dataFlowInstanceId)
Sets the data flow instance id
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.dataFlowInstanceUserObject(Object dataFlowInstanceUserObject)
Sets the user object associated to the data flow instance.
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.exceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
Sets the exception handler.
|
EPDataFlowInstantiationOptions |
EPDataFlowSavedConfiguration.getOptions()
Data flow instantiation options.
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.operatorProvider(EPDataFlowOperatorProvider operatorProvider)
Sets the the operator provider.
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.operatorStatistics(boolean statistics)
Sets indicator whether to collect operator statistics.
|
EPDataFlowInstantiationOptions |
EPDataFlowInstantiationOptions.parameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)
Sets the parameter provider.
|
Modifier and Type | Method and Description |
---|---|
EPDataFlowInstance |
EPDataFlowService.instantiate(String deploymentId,
String dataFlowName,
EPDataFlowInstantiationOptions options)
Instantiate a data flow, with options.
|
void |
EPDataFlowService.saveConfiguration(String dataflowConfigName,
String deploymentId,
String dataFlowName,
EPDataFlowInstantiationOptions options)
Save an existing data flow configuration (data flow name and its options) for later retrieval.
|
Constructor and Description |
---|
EPDataFlowSavedConfiguration(String savedConfigurationName,
String deploymentId,
String dataflowName,
EPDataFlowInstantiationOptions options)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPDataFlowInstance |
EPDataFlowServiceImpl.instantiate(String deploymentId,
String dataFlowName,
EPDataFlowInstantiationOptions options) |
void |
EPDataFlowServiceImpl.saveConfiguration(String dataflowConfigName,
String deploymentId,
String dataFlowName,
EPDataFlowInstantiationOptions options) |
Modifier and Type | Method and Description |
---|---|
static EPDataFlowInstance |
DataflowInstantiator.instantiate(int agentInstanceId,
DataflowDesc dataflow,
EPDataFlowInstantiationOptions options) |
static OperatorStatisticsProvider |
DataflowInstantiatorHelper.realize(DataflowDesc dataflow,
Map<Integer,Object> operators,
List<LogicalChannelBinding> bindings,
DataFlowSignalManager dataFlowSignalManager,
EPDataFlowInstantiationOptions options,
AgentInstanceContext agentInstanceContext) |
Copyright © 2005–2018. All rights reserved.