• Documentation
• StreamSets Calculator Documentation
• Calculator Library 0.0.2 Documentation

Calculator Library 0.0.2 Documentation

Note

This is a preview version of the StreamSets operators. The operator reference documentation is in Chinese only.

EnOS Stream Processing Service provides a set of underlying packaged StreamSets operators, supporting asset main data query, window aggregation, data filtering and interpolation, and electric energy calculation. Data engineers and application developers can use these StreamSets operators to design customized stream data processing jobs to meet the requirements of complex business scenarios.

Asset Data Querying Operators

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

Data Processing Operators

• Point Selector
• Asset Generator
• Partitioner
• Asset Partitioner
• Point Partitioner
• Time Sort
• Window Aggregator
• Fixed Batch Pivotor
• Earliest Change Record Appender
• State Capturer
• State Restorer

Advanced Data Processors

• Python Evaluator
• Available Objects:
• Add additional module search paths:
• HTTP Lookup

Data Quality Tagging Operators

• Late Point Filter
• MinMax Ouliter

Electric Energy Calculating Operators

• Last Record Appender
• Delta Calculator
• Delta Down Sampler