ForkRecord
描述:
此组件允许用户将一条记录分叉为多条记录。用户必须指定至少一个记录路径作为动态属性，指向包含记录对象的数组类型的字段。组件接受两种模式\uff1a“拆分”和“提取”。在这两种模式中，指定数组中包含的每个元素都生成一条记录。在“拆分”模式下，每个生成的记录将保留与输入中给定的相同的模板，但数组将只包含一个元素。在“提取”模式下，数组的元素必须是记录类型，并且将是生成的记录。此外，在“提取”模式下，可以指定每个生成的记录是否应该包含从根级别到提取记录的父记录的所有字段。这假定要添加到记录中的字段是在记录读取器控制器服务的模板中定义的。请参阅此组件的其他详细信息文档中的示例
标签:
fork, record, content, array, stream, event, 分叉, 记录, 内容, 数组, 流, 事件
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 记录读取服务 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于读取传入数据的控制器服务。 | |
| 记录输出服务 | 控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter | 指定用于写出记录的控制器服务。 | |
| 模式 | 拆分 | - 提取  - 拆分 | 指定处理器的分叉模式。 |
| 包括父字段 | 关闭使用父类型字段 | - 开启使用父类型字段 - 关闭使用父类型字段 | 此参数仅对“提取”模式有效。如果设置为true，则从根级别到给定数组的所有字段都将添加到要分叉的数组的每个元素的字段 |
连线:
| 名字 | 描述 |
|---|---|
| failure | 如果数据流在分支操作期间生成错误，它将被路由到此连线 |
| original | 原始数据流将路由到此连线 |
| fork | 包含分叉记录的数据流将被路由到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| record.count | 生成的数据流将具有一个“docum.count”属性，该属性指示写入数据流的记录数。 |
| mime.type | 记录输出相应的MIME类型 |
<Attributes from Record Writer> | Any Attribute that the configured Record Writer returns will be added to the FlowFile. |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。