MergeSnowflakeJournalTable 2025.10.2.19¶

Pacote¶

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

Descrição¶

Aciona uma operação de mesclagem em alterações da tabela de diário para uma tabela de destino no Snowflake. A operação de mesclagem é realizada de forma assíncrona e o processador pesquisa o resultado da operação. Se a consulta ainda estiver em andamento, o FlowFile será penalizado.

Tags¶

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Nome do banco de dados de destino	O nome do banco de dados Snowflake no qual os dados estão sendo ingeridos.
Contagem de tentativas de consulta de mesclagem	Indica quantas vezes a consulta de mesclagem deve ser tentada novamente em caso de falha.
Resolução do identificador do objeto	Controla como os identificadores dos objetos de origem (esquemas, tabelas, colunas) são armazenados e consultados no Snowflake. Essa configuração determina se você precisará usar aspas duplas em suas consultas SQL. A opção “Diferenciar maiúsculas e minúsculas” é o comportamento de produção padrão – “Não diferenciar maiúsculas e minúsculas” é considerada em versão preliminar por enquanto.
Valor do espaço reservado	O valor do espaço reservado da carga útil a ser procurado em um MERGE. Ele será convertido no tipo de dados da coluna de destino.
Pool de conexões Snowflake	O Controller Service usado para obter uma conexão com o banco de dados Snowflake para executar a operação de mesclagem.
Estratégia de valor inalterado	Determina como a consulta MERGE deve manipular valores inalterados em colunas de diário. Por padrão, ela espera valores completos.

Relações¶

Nome	Descrição
ddl	DDL para executar.
deleted during compaction	FlowFile excluído durante a compactação com base no nome e na geração da tabela.
failure	Falha na execução da consulta.
failure retry	Repetir a execução da consulta com falha.
poll query result	Execução de consulta assíncrona programada.
success	Execução bem-sucedida da consulta.
unknown file type	Tipo de arquivo desconhecido.

Grava atributos¶

Nome	Descrição
merge.query.id	O ID da consulta usada para mesclar a tabela de diário na tabela de destino.