SplitRecord 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

将面向记录的数据格式的输入 FlowFile 拆分成多个较小的 FlowFiles

标签

avro、csv、freeform、generic、json、log、logs、schema、split、text

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

记录读取器

指定用于读取传入数据的控制器服务

记录写入器

指定用于写出记录的控制器服务

每次拆分的记录

指定应向每个“拆分”或“分段”FlowFile 写入多少条记录

关系

名称

描述

failure

如果 FlowFile 无法从配置的输入格式转换为配置的输出格式,则未更改的 FlowFile 将路由到此关系。

original

成功拆分输入 FlowFile 后,原始 FlowFile 将发送到此关系。

splits

原始 FlowFile 的各个“片段”都将路由到此关系

写入属性

名称

描述

mime.type

将 mime.type 属性设置为记录写入器指定的 MIME 类型,适用于路由到“splits”关系的 FlowFiles。

record.count

FlowFile 中的记录数。此属性会添加到路由到“splits”关系的 FlowFiles 中。

fragment.identifier

由同一个父 FlowFile 生成的所有拆分 FlowFiles 都将带有为此属性添加的随机生成的相同 UUID

fragment.index

表示从单个父 FlowFile 创建的拆分 FlowFiles 的顺序的递增编号

fragment.count

从父 FlowFile 生成的拆分 FlowFiles 数量

segment.original.filename

父 FlowFile 的文件名

语言: 中文