UpdateSnowflakeDatabase 2025.10.2.19¶

バンドル¶

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

説明¶

受信 FlowFile で提供されたスキーマに基づいて、Snowflakeテーブルの定義を更新します。スキーマは、 FlowFile コンテンツを介して提供されているか、プロパティとして指定されているかを問わず、以下の形式の JSON にあることが想定されます。 { "columns": [ { "name": "<column name>", "type": "<column type>", "nullable": <true/false>, "precision": <precision, only for numeric type>, "scale": <scale, only for numeric type> }, ... ], "primaryKeys": ["<name of first primary key column>", "<name of second primary key column>", ...] }

タグ¶

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
列ストラテジーの追加	入力スキーマが既存のテーブルに存在しない列を持つ場合に使用するストラテジー。
Not Null ストラテジーの追加	入力スキーマに、既存のテーブルには存在しないnot-null制約がある場合に使用するストラテジーです。
列型の変更ストラテジー	既存のテーブルに、受信スキーマとは異なる型の列がある場合に使用するストラテジー。
列名の変換	スキーマで定義された列名に適用できるオプションの変換。この変換は、テーブルの既存の列と比較される前に、列名に適用されます。このプロパティは、属性に加えて、式言語を介して以下の変数をリファレンスできます。`column.name`、 `column.type`、 `column.nullable`、 `column.precision`、 `column.scale`、 `column.primaryKey`。
列の削除ストラテジー	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
接続プール	Snowflakeへの接続に使用する接続プール。
ストリームを作成	テーブルにSnowflakeストリームを作成するかどうか
作成パラメーター	CREATE TABLE ステートメントに含める追加パラメーター。例えば、 'CLUSTER BY (列名)' です。
目的スキーマ	必要なスキーマ/テーブル定義
列ストラテジーの削除	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
Not Nullストラテジーの削除	既存のテーブルにnot-null制約があり、それが入力スキーマに存在しない場合に使用するストラテジーです。
デフォルト値を含める	DEFAULT 値を CREATE TABLE または ALTER TABLE ADD COLUMN ステートメントに含めるかどうか
Nullでない制約を含む	CREATE TABLE または ALTER TABLE ADD COLUMN ステートメントに NOT NULL 制約を含めるかどうか。
プライマリキー制約を含む	作成ステートメントにプライマリキー制約を含めるかどうか
最大バッチサイズ	指定されたテーブルの1回の実行で処理できる FlowFiles の最大数。
プライマリキーストラテジーの変更	入力スキーマが既存のプライマリキーと異なるプライマリキーを持つ場合に使用するストラテジー。プライマリキーを変更するには、既存のキーを削除し、新しいキーを追加する必要があります。
Record Reader	目的のスキーマを取得するために使用するRecord Reader
列名サフィックスの削除	削除された列に付加するサフィックス。たとえば、列 'foo' の名前を 'foo__deleted' に変更するには、このプロパティを `__deleted` に設定します
スキーマ名	更新するスキーマの名前
ストリーム作成パラメーター	CREATE STREAM ステートメントに含める追加パラメーター。例えば、 'APPEND_ONLY=TRUE' です。
ストリーム名	ストリームの名前
テーブル・メタデータ・キャッシュの有効期限	キャッシュエントリが削除されるまでの時間（秒）。
テーブル名	ストリームを更新または作成するテーブルの名前。
テーブルスキーマストラテジー	必要なスキーマ/テーブル定義の取得方法を指定します。
テーブルストリーム作成パラメーター	CREATE STREAM ステートメントに含めるパラメーター。例えば、 'APPEND_ONLY=TRUE' です。ストリームは、テーブルをソースとして作成されます。
テーブルストリーム名	テーブルとともに作成されるストリームの名前。ストリーム・ソースは作成されたテーブルになります。
更新タイプ	実行するアップデートのタイプ
テーブル・メタデータ・キャッシュの使用	テーブルのメタデータをSnowflakeから直接読み込むのではなく、キャッシュするかどうか。[テーブルが存在しない場合はテーブルを作成、テーブルを変更] に適用されます。

リレーションシップ¶

名前	説明
failure	テーブルを更新できない場合、 FlowFile はこのリレーションシップにルーティングされます。
success	FlowFile は、テーブルが正常に更新された後、このリレーションシップにルーティングされます。

属性の書き込み¶

名前	説明
schema.hash	すべての更新が完了した後の、最終的なテーブルスキーマの SHA-256ハッシュ。変更検出とキャッシュの目的で使用できます。