com.espertech.esper.common.client.dataflow.core

Interface EPDataFlowService

public interface EPDataFlowService

Data flow runtime for instantiating data flows.

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE_DATAFLOWSTATE Type information

Method Summary

Modifier and Type	Method and Description
EPDataFlowDescriptor	getDataFlow(java.lang.String deploymentId, java.lang.String dataflowName) Returns a descriptor for the given data flow, or null if the data flow has not been declared.
com.espertech.esper.common.internal.util.DeploymentIdNamePair[]	getDataFlows() Returns the names of all declared data flows.
EPDataFlowSavedConfiguration	getSavedConfiguration(java.lang.String configurationName) Returns a saved dataflow configuration or null if it is not found.
java.lang.String[]	getSavedConfigurations() Returns the names of a saved data flow configurations.
EPDataFlowInstance	getSavedInstance(java.lang.String instanceName) Returns a specific saved data flow instance, or null if it has not been found
java.lang.String[]	getSavedInstances() Returns the instance names of a saved data flow instances.
EPDataFlowInstance	instantiate(java.lang.String deploymentId, java.lang.String dataflowName) Instantiate a data flow.
EPDataFlowInstance	instantiate(java.lang.String deploymentId, java.lang.String dataFlowName, EPDataFlowInstantiationOptions options) Instantiate a data flow, with options.
EPDataFlowInstance	instantiateSavedConfiguration(java.lang.String configurationName) Instantiate a data flow from a saved configuration.
boolean	removeSavedConfiguration(java.lang.String configurationName) Remove a previously saved data flow configuration.
boolean	removeSavedInstance(java.lang.String instanceName) Remove an instance previously saved.
void	saveConfiguration(java.lang.String dataflowConfigName, java.lang.String deploymentId, java.lang.String dataFlowName, EPDataFlowInstantiationOptions options) Save an existing data flow configuration (data flow name and its options) for later retrieval.
void	saveInstance(java.lang.String instanceName, EPDataFlowInstance instance) Save an existing instance with the runtime, for later retrieval.

Field Detail

EPTYPE_DATAFLOWSTATE

static final EPTypeClass EPTYPE_DATAFLOWSTATE

Type information

Method Detail

getDataFlow

EPDataFlowDescriptor getDataFlow(java.lang.String deploymentId,
                                 java.lang.String dataflowName)

Returns a descriptor for the given data flow, or null if the data flow has not been declared.

Parameters:

deploymentId - deployment id of dataflow (deployment id of create-dataflow statement)

dataflowName - data flow name

Returns:

data flow descriptor

getDataFlows

com.espertech.esper.common.internal.util.DeploymentIdNamePair[] getDataFlows()

Returns the names of all declared data flows.

Returns:

data flow names

instantiate

EPDataFlowInstance instantiate(java.lang.String deploymentId,
                               java.lang.String dataflowName)
                        throws EPDataFlowInstantiationException

Instantiate a data flow.

Parameters:

deploymentId - deployment id of dataflow (deployment id of create-dataflow statement)

dataflowName - name of data flow to instantiate

Returns:

data flow instance

Throws:

EPDataFlowInstantiationException - when the instantiation failed

instantiate

EPDataFlowInstance instantiate(java.lang.String deploymentId,
                               java.lang.String dataFlowName,
                               EPDataFlowInstantiationOptions options)
                        throws EPDataFlowInstantiationException

Instantiate a data flow, with options.

Parameters:

deploymentId - deployment id of dataflow (deployment id of create-dataflow statement)

dataFlowName - name of data flow to instantiate

options - populate options to control parameterization, instantiation etc.

Returns:

data flow instance

Throws:

EPDataFlowInstantiationException - when the instantiation failed

saveInstance

void saveInstance(java.lang.String instanceName,
                  EPDataFlowInstance instance)
           throws EPDataFlowAlreadyExistsException

Save an existing instance with the runtime, for later retrieval.

Parameters:

instanceName - name to use to save, must be unique among currently saved instances

instance - saved

Throws:

EPDataFlowAlreadyExistsException - if an instance by this name already exists

getSavedInstances

java.lang.String[] getSavedInstances()

Returns the instance names of a saved data flow instances.

Returns:

data flow instance names

getSavedInstance

EPDataFlowInstance getSavedInstance(java.lang.String instanceName)

Returns a specific saved data flow instance, or null if it has not been found

Parameters:

instanceName - to look for

Returns:

instance

removeSavedInstance

boolean removeSavedInstance(java.lang.String instanceName)

Remove an instance previously saved.

Parameters:

instanceName - to be removed

Returns:

indicator whether found or not

saveConfiguration

void saveConfiguration(java.lang.String dataflowConfigName,
                       java.lang.String deploymentId,
                       java.lang.String dataFlowName,
                       EPDataFlowInstantiationOptions options)
                throws EPDataFlowAlreadyExistsException,
                       EPDataFlowNotFoundException

Save an existing data flow configuration (data flow name and its options) for later retrieval.

Parameters:

dataflowConfigName - configuration name to save, must be unique

deploymentId - deployment id

dataFlowName - data flow name

options - options object

Throws:

EPDataFlowAlreadyExistsException - if the configuration name is already used

EPDataFlowNotFoundException - if the data flow by this name does not exist

getSavedConfigurations

java.lang.String[] getSavedConfigurations()

Returns the names of a saved data flow configurations.

Returns:

data flow configuration names

getSavedConfiguration

EPDataFlowSavedConfiguration getSavedConfiguration(java.lang.String configurationName)

Returns a saved dataflow configuration or null if it is not found.

Parameters:

configurationName - name to find

Returns:

data flow configuration

instantiateSavedConfiguration

EPDataFlowInstance instantiateSavedConfiguration(java.lang.String configurationName)
                                          throws EPDataFlowInstantiationException

Instantiate a data flow from a saved configuration.

Parameters:

configurationName - configuration name

Returns:

instance

Throws:

EPDataFlowInstantiationException - if the configuration name could not be found

removeSavedConfiguration

boolean removeSavedConfiguration(java.lang.String configurationName)

Remove a previously saved data flow configuration.

Parameters:

configurationName - to remove

Returns:

indicator whether found and removed