PickTablesForReplication 2025.10.2.19¶
Pacote¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Descrição¶
Accepts a list of fully qualified table names and determines if a table: - is new (is not replicated, but was added in the source) - is existing (is replicated and exists in the source) - is stale (is replicated but no longer exists in the source) Configuration is passed as a FlowFile attribute. Processor generates a separate FlowFile for each source 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 |