• 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

• Lastest 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