UpdateSnowflakeStream 2025.10.2.19¶
バンドル¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
説明¶
設定された操作に基づいてストリームを作成、削除、交換することで、Snowflakeストリームを管理します。Snowflakeのストリームは、テーブルのデータ変更をキャプチャし、 DML の経時的な変更を追跡するために使用できます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
接続プール |
Snowflakeへの接続に使用する接続プール。 |
オブジェクト識別子の解決 |
ソースオブジェクト識別子(スキーマ、テーブル、列)がSnowflakeにどのように格納され、クエリされるかを制御します。この設定により、 SQL クエリで二重引用符を使用する必要があるかどうかが決まります。 |
スキーマ名 |
ストリームおよび/またはソーステーブルを含んでいるスキーマの名前 |
ソーステーブル名 |
ストリームのソーステーブルの名前 |
ストリーム作成パラメーター |
CREATE STREAM ステートメントに含まれる追加のパラメーター。例:'APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE' |
ストリーム名 |
作成、ドロップ、または置換するストリームの名前 |
更新タイプ |
実行するストリーム操作のタイプ |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
ストリーム操作が完了できない場合、受信 FlowFile はこのリレーションシップにルーティングされます |
オブジェクトが見つかりません |
指定されたストリームまたはソーステーブルが存在しない場合、受信 FlowFile はこのリレーションシップにルーティングされます。 |
success |
受信 FlowFile は、ストリーム操作が正常に完了した後、このリレーションシップにルーティングされます。 |