UpdateSnowflakeIcebergDatabase 2025.5.31.15¶

バンドル¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

説明¶

Snowflake Icebergテーブルの定義を更新します。ターゲットスキーマは、 RecordReader から推論するか、以下の形式を使用して明示的に定義することができます:{ "columns": [ { "name": "<column name>", "type": "<iceberg data type>" }, ... ]} <iceberg データ型> がプリミティブIcebergタイプの1つである場所 ("string", "int", "boolean",...)- 与えられた精度とスケールを持つ10進数 ("decimal(P,S)")- {"type": "list", "element": <iceberg data type>}- {"type": "map", "key": <iceberg data type>, "value": <iceberg data type>}- {"type": "struct", "fields":[<list of struct fields>] }

タグ¶

iceberg

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
列ストラテジーの追加	入力スキーマが既存のテーブルに存在しない列を持つ場合に使用するストラテジー。
列ストラテジーの変更	列のデータ型が既存のテーブルと異なる場合に使用するスキーマ。
接続プール	Snowflakeへの接続に使用する接続プール。
目的スキーマ	必要なスキーマ/テーブル定義
列ストラテジーの削除	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
最大バッチサイズ	指定されたテーブルの1回の実行で処理できる FlowFiles の最大数。
Record Reader	目的のスキーマを取得するために使用するRecord Reader
スキーマ名	更新するスキーマの名前
テーブル・メタデータ・キャッシュの有効期限	キャッシュエントリが削除されるまでの時間（秒）。
テーブル名	更新するテーブルの名前
テーブルスキーマストラテジー	必要なスキーマ/テーブル定義の取得方法を指定します。
テーブル・メタデータ・キャッシュの使用	テーブルのメタデータをSnowflakeから直接読み込む代わりにキャッシュするかどうか

リレーションシップ¶

名前	説明
failure	テーブルを更新できない場合、 FlowFile はこのリレーションシップにルーティングされます。
違法改造	更新が失敗するように構成された変更を必要とする場合、受信 FlowFile は、このリレーションシップにルーティングされます。
success	FlowFile は、テーブルが正常に更新された後、このリレーションシップにルーティングされます。
テーブルが見つかりません	指定されたテーブルが存在しない場合、着信 FlowFile はこのリレーションシップにルーティングされます。