描述:
基于评估每个FlowFile上的表达语言表达式来跟踪滚动窗口,并将该值添加到处理器的状态。每个FlowFile将与FlowFiles的计数以及在当前时间窗口中处理的值的总合计值一起发出。
标签:
属性表达语言,状态,数据科学,滚动,窗口
特性:
在下面的列表中,必需属性的名称以粗体显示。其他任何属性(非粗体)均视为可选属性。该表还指示任何默认值,以及属性是否支持NiFi表达式语言。
名称 | 默认值 | 允许值 | 描述 |
---|---|---|---|
追踪价值 |
用于评估每个FlowFile的表达式。表达式的结果将添加到滚动窗口值中。 支持表达式语言:true(将使用流文件属性和变量注册表进行评估) |
||
时间窗 | 计算滚动窗口的时间窗口。 | ||
子窗口长度 | 设置后,值将被分批到设置长度的子窗口中。这允许设置更长的总窗口长度,但会牺牲一些精度。如果未设置(或为0),则每个值都以接收时的时间戳记为状态存储。在“时间”窗口中指定的时间过长后,该值将被删除。如果设置了此值,则将每隔X的时间量(其中X是为此属性设置的时间段)将值批处理在一起,然后一次将其全部删除。 |
关系:
名称 | 描述 |
---|---|
设置状态失败 | 当在处理FlowFile时无法保存状态时,会将FlowFile路由到此处。 |
成功 | 成功处理所有FlowFiles的路径在此处 |
失败 | 当FlowFile由于无法设置状态以外的其他原因而失败时,会将其路由到此处。 |
读取属性:
未指定。
写入属性:
名称 | 描述 |
---|---|
Rolling_window_value | 滚动窗口值(所有已存储值的总和)。 |
Rolling_window_count | 在滚动窗口中看到的FlowFiles数量的计数。 |
rolling_window_mean | 在滚动窗口中看到的FlowFiles的平均值。 |
状态管理:
范围 | 描述 |
---|---|
当地的 | 存储支持滚动窗口的值。这包括存储单个值及其时间戳,或一批值及其计数。 |
受限制的:
此组件不受限制。
输入要求:
该组件需要传入的关系。
系统资源注意事项:
未指定。