PartitionRecord 2025.5.31.15

バンドル

org.apache.nifi | nifi-standard-nar

説明

データ内の構成フィールドに基づいて、記録指向のデータを分割します。1つ以上のプロパティを追加する必要があります。プロパティの名前は、追加する属性の名前です。プロパティの値は、各記録に対して評価するための RecordPath です。2つの記録が同じアウトバウンド FlowFile に送られるのは、指定された RecordPaths のそれぞれの値が同じ場合のみです。指定された出力 FlowFile のすべての記録は、 RecordPath で指定されたフィールドに同じ値を持つことがわかっているため、各フィールドに属性が追加されます。詳細情報と使用例については、使用ページの「その他の詳細」を参照してください。

タグ

bin、group、organize、partition、record、recordpath、rpath、segment、split

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

record-reader

受信データの読み取りに使用するController Serviceを指定します。

record-writer

記録の書き出しに使用するController Serviceを指定します。

リレーションシップ

名前

説明

failure

FlowFile が構成された入力形式から構成された出力形式にパーティショニングできない場合、変更されていない FlowFile は、この関係にルーティングされます。

original

受信 FlowFile のすべての記録がパーティショニングされると、元の FlowFile はこのリレーションシップにルーティングされます。

success

FlowFiles がパーティショニングに成功すると、このリレーションにルーティングされます。

属性の書き込み

名前

説明

record.count

送信 FlowFile の記録数

mime.type

構成されたRecord Writerが適切であると示す MIME タイプ

フラグメント識別子

同じ親 FlowFile から生成されたすべてのパーティション FlowFiles は、この属性に対して同じランダム生成 UUID が追加されます。

フラグメント.インデックス

1つの親 FlowFile から作成されたパーティション FlowFiles の順序を示す1つ上の番号。

フラグメント.数

親 FlowFile から生成されたパーティション FlowFiles の数。

セグメント.オリジナル.ファイル名

親のファイル名 FlowFile

<動的プロパティ名>

追加される動的プロパティごとに、 FlowFile に属性を追加することができます。詳細情報については、Dynamic Propertiesの説明を参照してください。

ユースケース

記録を別々の FlowFiles に分け、 FlowFile のすべての記録が、指定されたフィールドまたはフィールドセットに対して同じ値を持つようにします。

特定の基準に準拠しているかどうかに基づいて記録を分離

こちらもご覧ください