UpdateSnowflakeDatabase 2025.5.31.15¶

バンドル¶

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": ["<第一プライマリキー列の名前>", "<第二プライマリキー列の名前>", ...]}

タグ¶

入力要件¶

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制約があり、それが入力スキーマに存在しない場合に使用するストラテジーです。
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 は、テーブルが正常に更新された後、このリレーションシップにルーティングされます。