ScriptedPartitionRecord 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-scripting-nar

説明¶

記録指向のデータ（構成されたRecord Readerで読み取り可能なデータ）を受信し、受信フローファイルの各記録に対してユーザー提供のスクリプトを評価します。その後、各記録は同じパーティションを共有する他の記録とグループ化され、各記録グループごとに FlowFile が作成されます。2つの記録が同じパーティションを共有するのは、スクリプトの評価結果が両方とも同じ返り値になる場合です。それらは同じパーティションの一部とみなされます。

タグ¶

groovy、グループ、整理、分割、記録、スクリプト、セグメント、分割

入力要件¶

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

false

プロパティ¶

プロパティ	説明
モジュールディレクトリ	スクリプトが必要とするモジュールを含むファイルやディレクトリへのパスをカンマで区切ったリスト。
Record Reader	入力された FlowFile を記録にパースするために使用するRecord Reader。
Record Writer	変換後の記録をシリアライズするために使用するRecord Writer。
本文	実行するスクリプト本文。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。
スクリプトエンジン	スクリプトに使用する言語
スクリプトファイル	実行するスクリプトファイルのパス。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。

制限事項¶

必要な許可	説明
実行コード	演算子に、 NiFi が持つすべてのパーミッションを想定して任意のコードを実行する能力を提供します。

リレーションシップ¶

名前	説明
failure	FlowFile が構成された入力形式から構成された出力形式にパーティショニングできない場合、変更されていない FlowFile は、この関係にルーティングされます。
original	受信 FlowFile のすべての記録がパーティショニングされると、元の FlowFile はこのリレーションシップにルーティングされます。
success	FlowFiles がパーティショニングに成功すると、このリレーションにルーティングされます。

属性の書き込み¶

名前	説明
partition	送信フローファイルのパーティション。スクリプトがパーティションにヌル値があることを示す場合、属性はリテラル文字列 "<null partition>" (引用符なし)にセットされます。そうでない場合、属性はスクリプトが返す値の文字列表現にセットされます。
mime.type	mime.type属性をRecord Writerで指定された MIME Typeにセットします。
record.count	フローファイル内の記録数。
record.error.message	この属性は、エラー時にリーダーまたはライターが遭遇したエラーメッセージを提供します。
フラグメント.インデックス	1つの親 FlowFile から作成されたパーティション FlowFiles の順序を示す1つ上の番号。
フラグメント.数	親 FlowFile から生成されたパーティション FlowFiles の数。