Operator Library 0.4.0 参考文档¶
平台抽象多个流数据处理基础算子，支持开发者自由拖拽式任务编排，满足更多业务场景的流数据处理任务开发。当前版本除了支持0.3.0版本所有功能外，新增功能如下：
支持新的数据流转格式
新增支持新版数据格式的算子（功能与旧版格式保持一致）
支持对数据中的测点和资产打标签（标签信息来自 数据资产目录 服务）
新增数据过滤算子，支持通过表达式对数据进行过滤后重命名
新旧算子结构详细信息¶
通用算子¶
支持原数据格式的算子¶
- Asset Lookup
- Child Asset Lookup
- Parent Asset Lookup
- Point Lookup
- Normalizer
- Point Selector
- Record Generator
- Virtual Record Generator
- Related Record Obtainer
- Partitioner
- Fixed Time Window Aggregator
- Sliding Time Window Aggregator
- Batch Merger
- Last Changed Record Appender
- Latest Record Merger
- Record Sorter By Time
- Dev Raw Data Source
- Trash
- 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
支持新数据格式的算子¶
- Asset Lookup*
- Child Asset Lookup*
- Parent Asset Lookup*
- Point Lookup*
- Point Selector*
- 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*
- Record Formatter
- Record Filter