ForkRecord 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

该处理器允许用户将一条记录分成多条记录。用户必须指定至少一个记录路径作为动态属性，用于指向包含 RECORD 对象的类型字段 ARRAY。处理器接受两种模式：“拆分”和“提取”。在这两种模式下，指定数组中包含的每个元素都会生成一条记录。在“拆分”模式下，每条生成的记录将保留与输入中给定的架构相同的架构，但数组将仅包含一个元素。在“提取”模式下，数组的元素必须是记录类型，并且将是生成的记录。此外，在“提取”模式下，可以指定每条生成的记录是否应包含父记录从根级别到提取记录的所有字段。这假设要在记录中添加的字段是在 Record Writer 控制器服务的架构中定义的。请参阅该处理器的其他详细信息文档中的示例。

标签¶

array、content、event、fork、record、stream

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
fork-mode	指定处理器的分叉模式
include-parent-fields	此参数仅在“提取”模式下有效。如果设置为 true，则从根级别到给定数组的所有字段都将添加为要分叉的数组中每个元素的字段。
record-reader	指定用于读取传入数据的控制器服务
record-writer	指定用于写出记录的控制器服务

关系¶

名称	描述
failure	如果 FlowFile 在分叉操作期间生成错误，则会将其路由到此关系
fork	包含分叉记录的 FlowFiles 将路由到此关系
original	原始 FlowFiles 将传送到此关系

写入属性¶

名称	描述
record.count	生成的 FlowFile 将具有“record.count”属性，表示写入到 FlowFile 的记录数。
mime.type	记录写入器指定的 MIME 类型
<Attributes from Record Writer>	配置的 Record Writer 返回的任何属性都将添加到 FlowFile。