MergeSnowflakeJournalTable 2025.5.31.15¶

Pacote¶

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

Descrição¶

Aciona uma operação de fusão nas 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.
Record Reader	O Record Reader a ser usado para ler a entrada
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.

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.