Operator Library 0.4.0 Documentation¶
EnOS Stream Processing Service provides multiple basic operators for stream data processing, enabling developers to compose customized stream data processing jobs to meet the requirements of complex business scenarios. This library contains all the calculators in the 0.3.0 Library and provides the following features:
- Supports new format of data forwarding.
- Added calculator that supports new format (Functions are the same as the format of previous version).
- Supports tagging measurement points and assets (The information of tags is sourced from Data Catalog).
- Added data filter calculator, and supports renaming data after filtering by expression.
Details of the old and new operator structures¶
Generic Operators¶
Operators supporting original data format¶
- Asset Lookup
- Child Asset Lookup
- Parent Asset Lookup
- Point Lookup
- Normalizer
- Point Selector
- Record Generator
- Virtual Record Generator
- Related Record Obtainer
- Partitioner
- Fixed Time Window Aggregator
- Sliding Time Window Aggregator
- Batch Merger
- Last Changed Record Appender
- Latest Record Merger
- Dev Raw Data Source
- Record Sorter By Time
- Trash
- Record Capturer
- Record Restorer
- Python Evaluator
- JavaScript
- Internal HTTP Client
- Late Point Tagger
- Off Limit Tagger
- Last Record Appender
- Cumulant Decomposer
- Simplified Time Window Aggregator
Operators supporting new data formats¶
- Asset Lookup*
- Child Asset Lookup*
- Parent Asset Lookup*
- Point Lookup*
- Point Selector*
- Fixed Time Window Aggregator*
- Sliding Time Window Aggregator*
- Batch Merger*
- Last Changed Record Appender*
- Latest Record Merger*
- Record Capturer*
- Record Restorer*
- Python Evaluator*
- JavaScript*
- Internal HTTP Client*
- Late Point Tagger*
- Off Limit Tagger*
- Last Record Appender*
- Cumulant Decomposer*
- Simplified Time Window Aggregator*
- Record Formatter
- Record Filter