ExtractRecordSchema 2025.5.31.15

バンドル

org.apache.nifi | nifi-standard-nar

説明

提供されたRecord Readerを使って FlowFile から記録スキーマを抽出し、 avro.schema 属性に書き込みます。

タグ

avro, csv, freeform, generic, json, record, schema, text, xml

入力要件

REQUIRED

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

false

プロパティ

プロパティ

説明

cache-size

キャッシュするスキーマの数を指定します。この値は、受信 FlowFiles に含まれる可能性のある、予想される異なるスキーマの数を反映する必要があります。これにより、スキーマの検索がより効率的になり、プロセッサーのパフォーマンスが向上します。

record-reader

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

リレーションシップ

名前

説明

failure

FlowFile の記録スキーマが構成された入力形式から抽出できない場合、 FlowFile はこのリレーションシップにルーティングされます。

success

FlowFiles 記録スキーマの抽出に成功した記録は、このリレーションシップにルーティングされます。

属性の書き込み

名前

説明

record.error.message

この属性は、Reader が遭遇したエラーメッセージを提供します。

avro.schema

この属性は、提供された RecordReader を用いて入力 FlowFile から抽出されたスキーマを提供します。