AvroRecordSetWriter

説明

RecordSet の内容をバイナリー Avro 形式で書き込みます。

タグ

avro, record, recordset, result, row, serializer, set, writer

プロパティ

以下のリストでは、必要なプロパティをアスタリスク (*) で表示しています。その他のプロパティはオプションと見なされます。この表は、任意のデフォルト値と、そのプロパティが NiFi 式言語に対応しているかどうかも示します。

表示名

API 名前

デフォルト値

許容値

説明

スキーマ リファレンス ライター *

スキーマ リファレンス ライター

FlowFile 属性またはコンテンツヘッダーにスキーマ参照情報を記述するサービスの実装。

スキーマ ストラテジー書き込み *

スキーマ ストラテジー書き込み

avro-embedded

  • Avroスキーマの埋め込み

  • スキーマを書かない

  • 'schema.name' 属性の設定

  • 'avro.schema' 属性の設定

  • スキーマ リファレンス ライター

記録のスキーマをデータに追加する方法を指定します。

キャッシュサイズ *

cache-size

1000

キャッシュするスキーマの数を指定します。

圧縮形式 *

compression-format

NONE

  • BZIP2

  • DEFLATE

  • NONE

  • SNAPPY

  • LZO

Avro ファイルの書き込みに使用する圧縮タイプ。デフォルトはNoneです。

エンコーダー・プール・サイズ *

encoder-pool-size

32

Avroライターにはエンコーダーが必要です。エンコーダーの作成にはコストがかかりますが、一度作成すれば再利用が可能です。このプロパティは、プールして再利用できるエンコーダーの最大数を制御します。この値を小さく設定しすぎるとパフォーマンスが低下しますが、大きく設定するとヒープがより多く使用されることになります。Avro Writer のスキーマ書き込みストラテジー 'Embed Avro Schema' で構成されている場合、このプロパティは無視されます。

スキーマアクセス戦略 *

schema-access-strategy

inherit-record-schema

  • 記録スキーマの継承

  • 'スキーマ名' プロパティの使用

  • 'スキーマテキスト' プロパティの使用

データの解釈に使用するスキーマの取得方法を指定します。

スキーマ支店

schema-branch

スキーマ・レジストリのプロパティでスキーマを検索する際に使用するブランチの名前を指定します。選択したスキーマ・レジストリが分岐をサポートしていない場合、この値は無視されます。

スキーマ キャッシュ

schema-cache

Record Readerがスキーマをすばやく検索できるように、記録スキーマを追加するスキーマキャッシュを指定します。

スキーマ名

schema-name

${schema.name}

スキーマ・レジストリのプロパティで検索するスキーマの名前を指定します。

スキーマ リファレンス リーダー *

schema-reference-reader

FlowFile 属性またはコンテンツを読み取ってスキーマ参照識別子を決定する責任を負うサービス実装。

スキーマレジストリ

schema-registry

スキーマレジストリで使用するController Serviceを指定します。

スキーマテキスト

schema-text

${avro.schema}

Avro形式のスキーマのテキスト

スキーマバージョン

schema-version

スキーマ・レジストリで検索するスキーマのバージョンを指定します。指定しない場合は、スキーマの最新バージョンが取得されます。

状態管理

このコンポーネントは状態を保存しません。

制限あり

このコンポーネントには制限はありません。

システムリソースに関する考察

このコンポーネントは、システムリソースを考慮したものではありません。