PickTablesForReplication 2025.5.31.15¶

バンドル¶

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

説明¶

完全修飾テーブル名のリストを受け入れ、テーブルが - 新しい (複製されていないが、ソースに追加された) - 存在する (複製されており、ソースに存在する) - 古い (複製されているが、ソースに存在しなくなった) かどうかを判断します。構成は FlowFile 属性として渡されます。プロセッサーは、ソース・テーブルごとに個別の FlowFile を生成します。

タグ¶

snowflake, state, table

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
テーブル状態サービス	現在複製されているテーブルとその状態を含むサービス

リレーションシップ¶

名前	説明
existing	すでに複製されている修飾されたテーブル名の FlowFile
failure	FlowFile 属性が読み取れないか、間違っている場合、このリレーションシップにルーティングされます。
new	複製されない修飾されたテーブル名の FlowFile
stale	以前は複製されていたが、ソースデータベースから削除されたか、パラメーターによって除外されたために複製されなくなったテーブル名を指定する FlowFile

属性の書き込み¶

名前	説明
source.schema.name	イベントの発生元テーブルのスキーマ名
source.table.name	イベントの発生元テーブル名