JoinEnrichment 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-standard-nar

説明¶

2つの異なる FlowFiles の記録を結合します。1つ目の FlowFile 「オリジナル」には任意の記録が含まれ、2つ目の FlowFile 「エンリッチメント」には、1つ目のデータをエンリッチするために使用されるべき追加データが含まれます。このプロセッサーの構成方法と、このプロセッサーが達成しようとするさまざまなユースケースの詳細については、「その他の詳細」を参照してください。

タグ¶

コンバイン、エンリッチメント、フォーク、結合、マージ、記録、レコードパス、SQL、ストリーム、ラップ

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
エンリッチメントRecord Reader	「エンリッチメント」 FlowFile を読むためのRecord Reader
挿入記録パス	「オリジナル」記録のどこに「エンリッチメント」記録のフィールドを挿入するかを指定します。RecordPath が元のレコードの既存のフィールドを指していない場合、エンリッチメントは挿入されません。
参加ストラテジー	2つの FlowFiles を1つの FlowFile に結合する方法を指定します。
Binsの最大数	一度にメモリに保持できるビンの最大数を指定します。
オリジナルRecord Reader	「オリジナル」 FlowFile を読むためのRecord Reader
Record Writer	結果の書き込みに使用するRecord Writer。Record Writer が Record からスキーマを継承するように構成されている場合、継承されるスキーマは「オリジナル」レコードスキーマと「エンリッチメント」レコードスキーマの両方をマージした結果になります。
SQL	評価する SQL SELECT ステートメント。式言語をプロバイダーとして提供することもできますが、そうすることでパフォーマンスが低下する可能性があります。このプロセッサーは一度に2つの FlowFiles を扱うので、属性がどのようにリファレンスされるかを理解することも重要です。両方の FlowFiles が、同じ名前で異なる値を持つ属性がある場合、式言語は 'enrichment' FlowFile によってプロバイダーが提供する値に解決します。
タイムアウト	最初の FlowFile が「timeout」関係にルーティングされた後、2 番目の FlowFile がプロセッサーに到着するまでの最大待機時間を指定します。
dbf-default-precision	DECIMAL/NUMBER の値が'10進数'Avro論理タイプとして記述される場合、利用可能な桁数を示す特定の'精度'が要求されます。一般的に、精度は列のデータ型の定義やデータベースエンジンのデフォルトによって定義されます。しかし、データベースエンジンによっては未定義の精度（0）が返されることがあります。デフォルトの10進数」は、未定義の精度の数値を書き込むときに使用されます。
dbf-default-scale	DECIMAL/NUMBER の値が'10進数'Avro論理タイプとして記述される場合、利用可能な10進数の桁数を示す特定の'スケール'が必要となります。一般的に、スケールは列のデータ型定義やデータベースエンジンのデフォルトで定義されます。しかし、未定義の精度(0)が返された場合、データベースエンジンによってはスケールが不確定になることもあります。「デフォルトの10進数」は、未定義の数値を書くときに使われます。もし数値が指定のスケールよりも小数点を持つなら、値は切り上げられます。例えば、1.53はスケール0では2になり、スケール1では1.5になります。

リレーションシップ¶

名前	説明
failure	オリジナル」と「エンリッチメント」 FlowFiles の両方がプロセッサーに到着したが、記録の結合に失敗した場合、それらの FlowFiles の両方がこのリレーションシップにルーティングされます。
joined	オリジナルとエンリッチメント FlowFiles の両方からレコードが結合された結果 FlowFile は、以下のリレーションシップにルーティングされます。
original	入ってくる FlowFiles (「オリジナル」と「エンリッチメント」) の両方が、このリレーションシップにルーティングされます。つまり、これはこれら FlowFiles 両方の「オリジナル」バージョンなのです。
timeout	着信する FlowFiles (すなわち、「オリジナル」 FlowFile または「エンリッチメント」 FlowFile) の一方がこのプロセッサーに到着したが、構成されたタイムアウト期間内にもう一方が到着しなかった場合、到着した FlowFile はこの関係にルーティングされる。

属性の書き込み¶

名前	説明
mime.type	mime.type属性をRecord Writerで指定された MIME Typeにセットします。
record.count	FlowFile の記録数。

こちらもご覧ください¶

org.apache.nifi.processors.standard.ForkEnrichment