SplitRecord

文档中心 › 组件索引 › SplitRecord

SplitRecord Processor

类型全限定名:cn.org.acal.lynxus.processors.standard.SplitRecord

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

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

标签

splitgenericschemajsoncsvavrologlogsfreeformtext

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
Record Reader控制器服务 API:
RecordReaderFactory
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
指定用于读取传入数据的 Controller Service
Record Writer控制器服务 API:
RecordSetWriterFactory
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
指定用于写出记录的 Controller Service
Records Per Split指定应将多少记录写入每个“拆分”或“分段”FlowFile
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)

关系 (Relationships)

名称描述自动终止
failure如果 FlowFile 无法从配置的输入格式转换为配置的输出格式,未更改的 FlowFile 将被路由到此关系。否
original成功分割输入FlowFile后,原始FlowFile将被发送到该关系。否
splits原始 FlowFile 的各个“段”将被路由到此关系。否

写入的 FlowFile 属性

名称描述
mime.type将 mime.type 属性设置为Record Writer为路由到“拆分”关系的 FlowFile 指定的 MIME 类型。
record.countFlowFile 中的记录数。 这将添加到路由到“拆分”关系的 FlowFiles 中。
fragment.identifier从同一父 FlowFile 生成的所有拆分 FlowFile 都将为此属性添加相同的随机生成的 UUID
fragment.index一个单数,指示从单个父 FlowFile 创建的分割 FlowFile 的顺序
fragment.count从父FlowFile生成的分割FlowFile的数量
segment.original.filename 父FlowFile的文件名

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。