UpdateSnowflakeDatabase 2025.10.2.19¶

Pacote¶

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

Descrição¶

Updates the definition of a Snowflake table based on the schema provided in the incoming FlowFile. The schema is expected to be in JSON with the following format, regardless of whether it is provided via FlowFile content or specified as a property: { «columns»: [ { «name»: «<column name>», «type»: «<column type>», «nullable»: <true/false>, «precision»: <precision, only for numeric type>, «scale»: <scale, only for numeric type> }, … ], «primaryKeys»: [«<name of first primary key column>», «<name of second primary key column>», …] }

Tags¶

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
Adicionar estratégia de não nulo	A estratégia a ser usada quando o esquema de entrada tem uma restrição não nula que não está presente na 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.
Transformação de nome de coluna	Uma transformação opcional que pode ser aplicada aos nomes das colunas definidas no esquema. Essa transformação é aplicada aos nomes das colunas antes de serem comparados com as colunas existentes na tabela. Essa propriedade pode fazer referência às seguintes variáveis por meio da linguagem de expressão, além dos atributos: `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey`.
Estratégia de remoção de coluna	A estratégia a ser usada quando a tabela existente tem uma coluna que não está presente no esquema de entrada
Pool de conexões	O pool de conexões a ser usado para se conectar ao Snowflake
Criar fluxo	Se você deve ou não criar um Snowflake Stream para a tabela
Parâmetros de criação	Parâmetros adicionais a serem incluídos na instrução CREATE TABLE. Por exemplo, “CLUSTER BY (column_name)”
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
Estratégia de descarte de não nulo	A estratégia a ser usada quando a tabela existente tem uma restrição não nula que não está presente no esquema de entrada
Incluir valores padrão	Whether or not to include DEFAULT values in CREATE TABLE or ALTER TABLE ADD COLUMN statements
Incluir restrições de não nulo	Incluir ou não as restrições NOT NULL nas instruções CREATE TABLE ou ALTER TABLE ADD COLUMN
Incluir restrições de chave primária	Se deve ou não incluir restrições de chave primária na instrução de criação
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.
Modificar estratégia de chave primária	A estratégia a ser usada quando o esquema de entrada tiver uma chave primária diferente da chave primária existente. A modificação da chave primária requer a eliminação da chave existente, se houver, e a adição de uma nova.
Record Reader	Record Reader a ser usado para obter o esquema desejado
Sufixo de nome de coluna removido	The suffix to append to a column that was removed. For example, to rename column “foo” to “foo__deleted”, the property can be set to `__deleted`
Nome do esquema	O nome do esquema a ser atualizado
Parâmetros de criação de fluxo	Parâmetros adicionais a serem incluídos na instrução CREATE STREAM. Por exemplo, “APPEND_ONLY=TRUE”
Nome de fluxo	O nome do fluxo
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 para atualizar ou criar o fluxo
Estratégia de esquema de tabela	Especifica como obter a definição do esquema/tabela desejado
Parâmetros de criação de fluxo de tabela	Parâmetros a serem incluídos na instrução CREATE STREAM. Por exemplo, “APPEND_ONLY=TRUE”. O fluxo será criado junto com a tabela como sua fonte.
Nome do fluxo de tabela	O nome do fluxo criado junto com a tabela. A fonte do fluxo será a tabela criada.
Tipo de atualização	O tipo de atualização a ser realizada
Usar cache de metadados da tabela	Se você deseja armazenar em cache os metadados da tabela em vez de lê-los diretamente do Snowflake. Aplica-se a [Criar tabela se não existir, Alterar tabela]

Relações¶

Nome	Descrição
failure	O FlowFile de entrada é encaminhado a essa relação se a tabela não puder ser atualizada
success	O FlowFile de entrada é encaminhado a essa relação após a atualização bem-sucedida da tabela

Grava atributos¶

Nome	Descrição
schema.hash	Um hash SHA-256 do esquema final da tabela após todas as atualizações terem sido concluídas. Pode ser usado para fins de detecção de alterações e cache.