UpdateSnowflakeIcebergDatabase 2025.10.2.19

Pacote

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

Descrição

Updates the definition of a Snowflake Iceberg table. A target schema can be inferred from a RecordReader or defined explicitly using the format below: { «columns»: [ { «name»: «<column name>», «type»: «<iceberg data type>» }, … ] } where <iceberg data type> can be one of: - primitive iceberg type («string», «int», «boolean»,…) - decimal with given precision and scale («decimal(P,S)») - {«type»: «list», «element»: <iceberg data type>} - {«type»: «map», «key»: <iceberg data type>, «value»: <iceberg data type>} - {«type»: «struct», «fields»:[<list of struct fields>] }

Tags

iceberg

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Adicionar estratégia de coluna

A estratégia a ser usada quando o esquema de entrada tem uma coluna que não está presente na tabela existente

Alterar estratégia de coluna

A estratégia a ser usada quando uma coluna tem um tipo de dados diferente no esquema de entrada da tabela existente

Alter Column Type Strategy

The strategy to use when the existing table has a column with a different type than the incoming schema.

Pool de conexões

O pool de conexões a ser usado para se conectar ao Snowflake

Esquema desejado

A definição do esquema/tabela desejado

Estratégia de descarte de coluna

A estratégia a ser usada quando a tabela existente tem uma coluna que não está presente no esquema de entrada

Tamanho máximo do lote

O número máximo de FlowFiles que pode ser processado em uma única execução para uma determinada tabela.

Record Reader

Record Reader a ser usado para obter o esquema desejado

Nome do esquema

O nome do esquema a ser atualizado

Tempo de expiração do cache de metadados da tabela

O tempo em segundos após o qual a entrada do cache será removida

Nome da tabela

O nome da tabela a ser atualizada

Estratégia de esquema de tabela

Especifica como obter a definição do esquema/tabela desejado

Usar cache de metadados da tabela

Se os metadados da tabela devem ser armazenados em cache em vez de lê-los diretamente do Snowflake

Relações

Nome

Descrição

failure

O FlowFile de entrada é encaminhado a essa relação se a tabela não puder ser atualizada

illegal alteration

O FlowFile de entrada é encaminhado para essa relação se a atualização exigir uma alteração que esteja configurada para falhar

success

O FlowFile de entrada é encaminhado a essa relação após a atualização bem-sucedida da tabela

tabela não encontrada

O FlowFile de entrada é encaminhado para essa relação se a tabela especificada não existir.

Grava atributos

Nome

Descrição

schema.hash

Um hash SHA-256 codificado em hexadecimal do esquema final da tabela após a conclusão de todas as atualizações.