FetchSourceTableSchema 2025.10.2.19¶

Pacote¶

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

Descrição¶

Busca o esquema (ou seja, nomes de colunas, tipos de dados etc.) para uma determinada tabela em um banco de dados, convertendo os tipos de dados em tipos compatíveis com o Snowflake. O esquema é gravado no conteúdo do FlowFile como um objeto JSON, em um formato como: { «columns»: [ { «name»: «<columnName>», «type»: «<snowflakeType>», «nullable»: <true|false>, «scale»: <scale>, «precision»: <precision> }, … ], «primaryKeys»: [«<primaryKey1>», «<primaryKey2>», …] }

Tags¶

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Serviço de filtro de colunas	Especifica o serviço de filtro de colunas a ser usado para filtrar colunas indesejadas
Pool de conexões	O pool de conexões a ser usado para buscar o esquema da tabela de origem
Nome do esquema	O nome do esquema no qual a tabela de origem está armazenada
Nome da tabela	O nome da tabela de origem

Relações¶

Nome	Descrição
failure	FlowFiles são encaminhados para essa relação caso o esquema da tabela de origem não possa ser obtido
success	FlowFiles são encaminhados para essa relação quando o esquema da tabela de origem é obtido com sucesso
tabela não encontrada	FlowFiles são roteados para essa relação quando a tabela de origem não existe

Grava atributos¶

Nome	Descrição
mime.type	applicativo/json
dbms.type	O tipo de sistema de gerenciamento de banco de dados (DBMS) no qual a tabela de origem está armazenada. Por exemplo, `POSTGRESQL`
primary.key.count	O número de chaves primárias na tabela de origem
column.count	O número de colunas na tabela de origem