SplitRecord Processor
描述
将面向记录的数据格式的输入FlowFile分割成多个较小的FlowFile
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Record Reader | | 控制器服务 API:RecordReaderFactorycn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定用于读取传入数据的 Controller Service |
| Record Writer | | 控制器服务 API:RecordSetWriterFactorycn.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.count | FlowFile 中的记录数。 这将添加到路由到“拆分”关系的 FlowFiles 中。 |
fragment.identifier | 从同一父 FlowFile 生成的所有拆分 FlowFile 都将为此属性添加相同的随机生成的 UUID |
fragment.index | 一个单数,指示从单个父 FlowFile 创建的分割 FlowFile 的顺序 |
fragment.count | 从父FlowFile生成的分割FlowFile的数量 |
segment.original.filename | 父FlowFile的文件名 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。