FetchSourceTableSchema 2025.3.28.13-SNAPSHOT¶
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>”, …]}
INPUT REQUIREMENT¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
|---|---|
Column Filter Service |
Specifies the Column Filter Service to be used for filtering out unwanted columns |
Connection Pool |
The connection pool to use to fetch the source table schema |
Schema Name |
The name of the schema that the source table is stored in |
Table Name |
The name of the source table |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
|---|---|
failure |
FlowFiles are routed to this relationship in the event that the source table’s schema cannot be fetched |
table not found |
FlowFiles are routed to this relationship when the source table does not exist |
success |
FlowFiles are routed to this relationship when the source table’s schema is successfully fetched |
WRITES ATTRIBUTES¶
NAME |
DESCRIPTION |
|---|---|
mime.type |
application/json |
dbms.type |
The type of database management system (DBMS) that the source table is stored in. E.g. |
primary.key.count |
The number of primary keys in the source table |
column.count |
The number of columns in the source table |