PartitionRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
根据数据中配置的字段对面向记录的数据进行拆分或分区。必须添加一个或多个属性。该属性的名称是要添加的属性的名称。该属性的值为 RecordPath，用于对照每条记录进行评估。只有当两条记录的给定 RecordPaths 值相同时，它们才会被写入同一个出站 FlowFile。因为我们知道给定输出 FlowFile 中的所有记录对于由 RecordPath 指定的字段具有相同的值，因此会为每个字段添加一个属性。有关更多信息和示例，请参阅“Usage”页面上的“Additional Details”。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
record-reader |
指定用于读取传入数据的控制器服务 |
record-writer |
指定用于写出记录的控制器服务 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 FlowFile 无法从配置的输入格式分区到配置的输出格式，则未更改的 FlowFile 将路由到此关系。 |
original |
对传入 FlowFile 中的所有记录进行分区后，原始 FlowFile 将路由到此关系。 |
success |
成功分区的 FlowFiles 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
record.count |
传出 FlowFile 中的记录数 |
mime.type |
已配置的记录写入器指示的 MIME 类型是合适的 |
fragment.identifier |
由同一个父 FlowFile 生成的所有 FlowFiles 分区都将带有相同的随机生成的 UUID 作为此属性 |
fragment.index |
表示从单个父 FlowFile 创建的分区 FlowFiles 的顺序的递增编号 |
fragment.count |
从父 FlowFiles 生成的分区 FlowFile 数量 |
segment.original.filename |
父 FlowFile 的文件名 |
<dynamic property name> |
对于添加的每个动态属性，可以将一个属性添加到 FlowFile。有关更多信息，请参阅“动态属性”的描述。 |
用例¶
将记录分成多个单独的 FlowFiles，以使 FlowFile 中的所有记录在给定字段或字段组中都有相同的值。 |
根据记录是否符合特定标准对记录进行拆分 |