• 文档
• StreamSets算子参考说明
• Calculator Library 0.1.0 参考文档

Calculator Library 0.1.0 参考文档

Streaming Calculator Library 0.1.0 包含主数据关联、聚合算法、插补策略、基于事件时间的时间窗口、以及阈值过滤等算子。

数据源算子（Origin）

• Dev Raw Data Source

资产主数据算子

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

数据处理算子

• Point Selector
• Record Generator
• Partitioner
• Record Sorter By Time
• 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

目标算子（Destination）

• Trash

算子性能说明

• 算子性能说明