Package | Description |
---|---|
com.espertech.esper.client.dataflow |
Client API for data flows.
|
com.espertech.esper.dataflow.core |
Data flow core classes.
|
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 |
EPDataFlowRuntime.instantiate(String dataFlowName,
EPDataFlowInstantiationOptions options)
Instantiate a data flow, with options.
|
void |
EPDataFlowRuntime.saveConfiguration(String dataflowConfigName,
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 dataflowName,
EPDataFlowInstantiationOptions options)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPDataFlowInstance |
DataFlowServiceImpl.instantiate(String dataFlowName,
EPDataFlowInstantiationOptions options) |
static DataflowStartDesc |
RealizationFactoryInterface.realize(String dataFlowName,
Map<Integer,Object> operators,
Map<Integer,OperatorMetadataDescriptor> operatorMetadata,
Set<Integer> operatorBuildOrder,
List<LogicalChannelBinding> bindings,
DataFlowSignalManager dataFlowSignalManager,
EPDataFlowInstantiationOptions options,
EPServicesContext services,
StatementContext statementContext) |
void |
DataFlowServiceImpl.saveConfiguration(String dataflowConfigName,
String dataFlowName,
EPDataFlowInstantiationOptions options) |