PickTablesForReplication 2025.5.31.15¶

Pacote¶

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

Descrição¶

Aceita uma lista de nomes de tabelas totalmente qualificados e determina se uma tabela: é nova (não é replicada, mas foi adicionada na fonte); é existente (é replicada e existe na fonte); ou é obsoleta (é replicada, mas não existe mais na fonte). A configuração é passada como um atributo do FlowFile. O processador gera um FlowFile separado para cada tabela de origem.

Tags¶

snowflake, state, table

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Serviço de estado da tabela	Um serviço que contém tabelas replicadas no momento e seus estados

Relações¶

Nome	Descrição
existing	O FlowFile com nome de tabela qualificado que já está sendo replicado
failure	Se um atributo do FlowFile não puder ser lido ou estiver incorreto, ele será encaminhado para essa relação.
new	O FlowFile com nome de tabela qualificado que não foi replicado
stale	O FlowFile com nome de tabela qualificado que costumava ser replicado, mas não é mais, seja porque foi removido do banco de dados de origem ou excluído pelo parâmetro

Grava atributos¶

Nome	Descrição
source.schema.name	Nome do esquema de tabela da qual um evento se originou
source.table.name	Nome da tabela da qual um evento se originou