Simplified Time Window Aggregator¶
支持对指定时间间隔内到达的Record进行窗口聚合，输出所有Record的总和。每当有Record到达时触发计算。该算子为电量计算专用。
配置详情¶
该算子的配置包括 General，Basic，和 Input/Output 的详细信息，各字段的配置如下：
General¶
名称 |
是否必须 |
描述 |
|---|---|---|
Name |
Yes |
算子名称 |
Description |
No |
算子描述 |
Stage Library |
Yes |
算子所属的库 |
Required Fields |
No |
数据必须包含的字段，如果未包含指定字段，则record将被过滤掉 |
Preconditions |
No |
数据必须满足的前提条件，如果不满足指定条件，则record将被过滤掉 |
On Record Error |
Yes |
对错误数据的处理方式，可选：
|
Basic¶
名称 |
是否必须 |
描述 |
|---|---|---|
Quality Filter |
No |
根据数据质量过滤处理数据，只有符合质量条件的record才会进行此次处理 |
Input/Output¶
名称 |
是否必须 |
描述 |
|---|---|---|
Input Point |
Yes |
数据输入点，格式为：{模型标识}::{测点标识}。同一行的输入点和输出点之间的modelId必须相同，pointId必须不同。 |
Aggregate Window |
Yes |
选择时间窗口的大小，即输出聚合计算结果的时间间隔。 |
Output Point |
Yes |
数据输出点，格式为：{模型标识}::{测点标识}。同一行的输入点和输出点之间的modelId必须相同，pointId必须不同。所有的输出点不能重复。 |
输出结果¶
输出示例¶
