FetchSourceTableSchema 2025.10.2.19¶

Bundle¶

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

Description¶

Fetches the table schema (i.e., column names, data types, etc.) for a given table in a database, converting the data types to Snowflake-compatible types. The schema is written to the FlowFile content as a JSON object, in a form such as: { « columns »: [ { « name »: « <columnName> », « type »: « <snowflakeType> », « nullable »: <true|false>, « scale »: <scale>, « precision »: <precision> }, … ], « primaryKeys »: [« <primaryKey1> », « <primaryKey2> », …] }

Balises¶

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Service de filtre de colonne	Spécifie le service de filtrage des colonnes à utiliser pour filtrer les colonnes indésirables
Connection Pool	Le pooling de connexions à utiliser pour récupérer le schéma de la table source
Nom de schéma	Le nom du schéma dans lequel la table source est stockée
Nom de la table	Le nom de la table source

Relations¶

Nom	Description
failure	Les FlowFiles sont routés vers cette relation dans l’événement où le schéma de la table source ne peut pas être récupéré
success	Les FlowFiles sont routés vers cette relation lorsque le schéma de la table source est récupéré avec succès
table non trouvée	Les FlowFiles sont routés vers cette relation lorsque la table source n’existe pas

Écrit les attributs¶

Nom	Description
mime.type	application/json
dbms.type	Le type de système de gestion de base de données (DBMS) dans lequel la table source est stockée. Par exemple `POSTGRESQL`
primary.key.count	Le nombre de clés primaires dans la table source
column.count	Le nombre de colonnes dans la table source