MergeSnowflakeJournalTable 2025.10.2.19¶

Pacote¶

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

Descrição¶

Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the FlowFile will be penalized.

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.