| Interface | Description |
|---|---|
| IOnDemandProcessInstance |
Interface for on-demand process instances.
An instance may connect to an archive or streaming data source and MUST generate data events for each new record produced on any of its output. The output can be an aggregate (e.g. |
| IOnDemandProcessModule<ConfigType extends ProcessConfig> |
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. |
| IProcessingManager |
Management interface for process implementations
|
| IProcessModule<ConfigType extends ProcessConfig> |
Base interface for all SensorHub data processing modules
|
| IProcessOutput | |
| IStreamProcessModule<ConfigType extends StreamProcessConfig> |
Interface for all event stream processors.
This type of process is started in a persistent manner and listens to incoming events. |
| Class | Description |
|---|---|
| DataSourceConfig |
Config class for specifying a data source for a processing module
|
| DataSourceConfig.InputLinkConfig | |
| OnDemandProcessConfig |
Base for all stream processors config classes
|
| ProcessConfig |
Configuration options for processing modules
|
| ProcessDataSourceConfig |
Data source configuration to get process input data from another process
|
| ProcessingEvent |
Simple base data structure for all events linked to processing modules
|
| StorageDataSourceConfig |
Data source configuration to get process input data from a data store
|
| StreamingDataSourceConfig |
Data source configuration to get process input from a stream of data events
|
| StreamProcessConfig |
Base for all stream processor config classes
|
| Enum | Description |
|---|---|
| ProcessingEvent.Type |
Possible event types for a ProcessingEvent
|
| Exception | Description |
|---|---|
| ProcessException |
Exceptions generated by process implementations
|