• Documentation
• Supported StreamSets Operators

Supported StreamSets Operators

EnOS Edge provides encapsulated StreamSets operators for stream analytics tasks such as asset data query, data aggregating, imputation, event-based time window, and threshold filer. Developers can create stream analytics tasks by orchestrating the operators for complicated calculations. EnOS Edge supports the following operators:

Asset Data Querying Operators

• TSL Asset Lookup
• TSL Child Asset Lookup
• TSL Parent Asset Lookup
• TSL Point Lookup

Data Processing Operators

• Point Selector
• Record Sorter By Time
• Fixed Time Window Aggregator
• Sliding Time Window Aggregator
• Last Changed Record Appender
• Record Capturer
• Latest Record Merger
• Record Generator
• Partitioner
• Batch Merger
• Record Restorer

Advanced Data Processors

• Internal HTTP Client
• JavaScript

Data Quality Tagging Operators

• Late Point Tagger
• Off Limit Tagger

Electric Energy Calculating Operators

• Last Record Appender
• Cumulant Decomposer
• Simplified Time Window Aggregator

Destination

• Trash