UpdateSnowflakeIcebergDatabase 2025.5.31.15¶

Pacote¶

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

Descrição¶

Atualiza a definição de uma tabela Snowflake Iceberg. Um esquema de destino pode ser inferido de um RecordReader ou definido explicitamente usando o formato abaixo: { «columns»: [ { «name»: «<column name>», «type»: «<iceberg data type>» }, …]} onde <tipo de dados iceberg> pode ser um dos seguintes: tipo de iceberg primitivo (“cadeia de caracteres”, “inteiro”, “booliano” …); decimal com precisão e escala determinadas (“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
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.