QueryRecord 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-standard-nar

説明¶

FlowFile のコンテンツに対して、1 つ以上の SQL クエリを評価します。SQL クエリの結果が、出力 FlowFile の内容となります。これは、フィールド固有のフィルター、変換、行レベルのフィルターなどに使用できます。列の名前を変更したり、簡単な計算や集計を行ったりすることができます。プロセッサーは、入出力データ形式に柔軟性を持たせるため、Record ReaderController ServiceとRecord Writerサービスで構成されています。プロセッサーは、少なくとも 1 つのユーザー定義プロパティを構成する必要があります。Property の名前は、データをルーティングする Relationship であり、Property の値は、入力データがどのように変換/フィルタリングされるべきかを指定するために使用される SQL SELECT ステートメントです。SQL ステートメントは、有効な ANSI SQL である必要があり、Apache Calcite を使用しています。変換に失敗した場合、元の FlowFile は「失敗」リレーションシップにルーティングされます。そうでない場合、選択されたデータは関連するリレーションシップにルーティングされます。Record Writerが記録からスキーマを継承することを選択した場合、継承されるスキーマは入力記録ではなく ResultSet からのものであることに注意することが重要です。これにより、 QueryRecord プロセッサーの1つのインスタンスが複数のクエリを持つことができ、それぞれが異なる列と集約のセットを返します。しかし、その結果、派生するスキーマはスキーマ名を持たないので、記録からスキーマを継承する場合、構成されたRecord Writerは属性としてスキーマ名を書こうとしないことが重要です。詳細情報については、Processor Usageドキュメントを参照してください。

タグ¶

aggregate, avro, calcite, csv, etl, filter, json, logs, modify, query, record, route, select, sql, text, transform, update

入力要件¶

REQUIRED

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

false

プロパティ¶

リレーションシップ¶

属性の書き込み¶

ユースケース¶