JoltTransformRecord 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-jolt-nar
説明¶
FlowFile ペイロードの各記録に JOLT 仕様を適用します。変換されたコンテンツで新しい FlowFile が作成され、「成功」リレーションシップにルーティングされます。変換 が失敗した場合、元の FlowFile は「失敗」リレーションシップにルーティングされます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
---|---|
カスタムモジュールディレクトリ |
(NiFi のクラスパスに含まれていない) カスタム変換を含むモジュールを含むファイルやディレクトリへのパスをカンマ区切りにしたリスト。 |
カスタム変換クラス名 |
カスタム変換の完全修飾クラス名 |
Jolt 仕様 |
JSON データの変換のためのJolt仕様。このプロパティの値は、Jolt仕様のテキスト、またはJolt仕様を含むファイルへのパスです。「Jolt仕様」がセットされている必要があり、Joltソート変換が選択されている場合、値は無視されます。 |
Jolt変換 |
プロバイダー仕様で使用されるべきJolt Transformationを指定します。 |
変換キャッシュサイズ |
Jolt Transformのコンパイルにはかなりコストがかかります。理想的には、この作業は一度だけです。しかし、式言語がトランスフォームに使われている場合、 FlowFile ごとに新しいトランスフォームが必要になるかもしれません。この値は、毎回Transformをコンパイルする必要がないように、メモリにキャッシュするTransformの数を制御します。 |
jolt-record-record-reader |
受信データのパースやデータのスキーマの決定に使用する Controller Service を指定します。 |
jolt-record-record-writer |
記録の書き出しに使用するController Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
---|---|
failure |
FlowFile が何らかの理由で処理に失敗した場合 (例えば、 FlowFile の記録が解析できない場合)、このリレーションシップにルーティングされます。 |
original |
変換された元の FlowFile。FlowFile が処理に失敗した場合、このリレーションシップには何も送られません。 |
success |
変換されたコンテンツを持つ FlowFile は、このリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
---|---|
record.count |
送信 FlowFile の記録数 |
mime.type |
構成されたRecord Writerが適切であると示す MIME タイプ |