PickTablesForReplication 2025.10.2.19¶

バンドル¶

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	イベントの発生元テーブル名