ConfigType
- Type of configuration classpublic interface IOnDemandProcessModule<ConfigType extends ProcessConfig> extends IProcessModule<ConfigType>
Base interface for on-demand processing modules.
This type of module is configured to fetch data from fixed streaming or
archive sources, but can be further parameterized for each execution.
The caller is responsible for getting new process instances when appropriate:
A single process instance can be reused several times sequentially, but
separate instances are needed to launch in parallel.
CANNOT_INIT_MSG, CANNOT_LOAD_MSG, CANNOT_START_MSG, CANNOT_STOP_MSG, CANNOT_UPDATE_MSG
Modifier and Type | Method and Description |
---|---|
IOnDemandProcessInstance |
getNewProcessInstance()
Retrieves a new instance of this processor configured with default data sources
|
java.util.Map<java.lang.String,? extends DataComponent> |
getParameterDescriptors()
Gets the list of parameters for this process.
Default parameter values can be set here but actual values are given to each process instance using one of the execute methods. |
getInputDescriptors, getOutputDescriptors, isCompatibleDataSource
cleanup, getConfiguration, getCurrentError, getCurrentState, getLocalID, getName, getStatusMessage, init, init, isInitialized, isStarted, loadState, registerListener, requestInit, requestStart, requestStop, saveState, setConfiguration, start, stop, unregisterListener, updateConfig, waitForState
java.util.Map<java.lang.String,? extends DataComponent> getParameterDescriptors()
IOnDemandProcessInstance getNewProcessInstance()