AttributeRollingWindow Processor
描述
基于对每个 FlowFile 评估Expression Language表达式来跟踪滚动窗口，并将该值添加到处理器的状态中。 每个 FlowFile 将被发出，并附带当前时间窗口内已处理的 FlowFile 数量和值的总聚合值。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Value to Track | | 用于评估每个 FlowFile 的表达式。 表达式的结果将被添加到滚动窗口值中。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Time Window | | 用于计算滚动窗口的时间窗口。 | |
| Sub-window Length | | 设置后，值将被分批到设定长度的子窗口中。这允许设置更大的总窗口长度，但会牺牲一些精度。如果未设置（或为 0），则每个值都会与其接收时的时间戳一起存储在状态中。在Time Window中指定的时间长度过后，该值将被移除。如果设置了此值，值将每隔 X 时间（X 为此属性设置的时间段）分批在一起，并一次性全部移除。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 当 FlowFile 因设置状态以外的原因失败时，被路由到这里。 | 否 |
set state fail | 当处理 FlowFile 时状态保存失败，FlowFile 被路由到这里。 | 否 |
success | 所有成功处理的 FlowFile 都被路由到这里 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
rolling_window_value | 滚动窗口值（所有存储值的总和）。 |
rolling_window_count | 滚动窗口中看到的 FlowFile 数量。 |
rolling_window_mean | 滚动窗口中看到的 FlowFile 的平均值。 |
rolling_window_variance | 滚动窗口中看到的 FlowFile 的方差。 |
rolling_window_stddev | 滚动窗口中看到的 FlowFile 的标准差（方差的正平方根）。 |
状态管理
| 作用域 | 描述 |
|---|---|
| LOCAL | 存储支持滚动窗口的值。 包括存储各个值及其时间戳，或值的批次及其数量。 |
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。