FetchSourceTableSchema 2025.5.31.15¶
Pacote¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Descrição¶
Obtém o esquema da tabela (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>», …]}
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, |
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 |