AttributeRollingWindow 1.13.2

描述:

基于评估每个FlowFile上的表达语言表达式来跟踪滚动窗口,并将该值添加到处理器的状态。每个FlowFile将与FlowFiles的计数以及在当前时间窗口中处理的值的总合计值一起发出。

标签:

属性表达语言,状态,数据科学,滚动,窗口

特性:

在下面的列表中,必需属性的名称以粗体显示其他任何属性(非粗体)均视为可选属性。该表还指示任何默认值,以及属性是否支持NiFi表达式语言

名称 默认值 允许值 描述
追踪价值     用于评估每个FlowFile的表达式。表达式的结果将添加到滚动窗口值中。
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
时间窗     计算滚动窗口的时间窗口。
子窗口长度     设置后,值将被分批到设置长度的子窗口中。这允许设置更长的总窗口长度,但会牺牲一些精度。如果未设置(或为0),则每个值都以接收时的时间戳记为状态存储。在“时间”窗口中指定的时间过长后,该值将被删除。如果设置了此值,则将每隔X的时间量(其中X是为此属性设置的时间段)将值批处理在一起,然后一次将其全部删除。

关系:

名称 描述
设置状态失败 当在处理FlowFile时无法保存状态时,会将FlowFile路由到此处。
成功 成功处理所有FlowFiles的路径在此处
失败 当FlowFile由于无法设置状态以外的其他原因而失败时,会将其路由到此处。

读取属性:

未指定。

写入属性:

名称 描述
Rolling_window_value 滚动窗口值(所有已存储值的总和)。
Rolling_window_count 在滚动窗口中看到的FlowFiles数量的计数。
rolling_window_mean 在滚动窗口中看到的FlowFiles的平均值。

状态管理:

范围 描述
当地的 存储支持滚动窗口的值。这包括存储单个值及其时间戳,或一批值及其计数。

受限制的:

此组件不受限制。

输入要求:

该组件需要传入的关系。

系统资源注意事项:

未指定。

AttributeRollingWindow 1.13.2

上一篇:最新win10教育版激活密匙永久激活序列号


下一篇:[NET,C# ] Nuget包发布流程