• 文档
• 支持的StreamSets算子列表

支持的StreamSets算子列表

EnOS Edge流数据分析服务开放多个底层封装好的StreamSets算子，支持主数据关联、聚合算法、插补策略、基于事件时间的时间窗口、以及阈值过滤等计算。供开发者通过编排算子创建流数据分析任务，满足更多复杂场景的业务计算。EnOS Edge支持以下算子：

资产主数据算子

• TSL Asset Lookup

• TSL Child Asset Lookup

• TSL Parent Asset Lookup

• TSL Point Lookup

数据处理算子

• 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

其他数据处理算子

• Internal HTTP Client

• JavaScript

数据质量算子

• Late Point Tagger

• Off Limit Tagger

电量计算算子

• Last Record Appender

• Cumulant Decomposer

• Simplified Time Window Aggregator

目标算子（Destination）

• Trash