FetchSourceTableSchema 2025.10.2.19¶

捆绑包¶

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

描述¶

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>", ...] }

标签¶

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
Column Filter Service	指定用于筛选掉不需要的列的 Column Filter Service
连接池	用于提取源表架构的连接池
架构名称	存储源表的架构的名称
表名称	源表的名称

关系¶

名称	描述
failure	如果无法获取源表的架构，则会将 FlowFiles 路由到此关系
success	成功提取源表的架构后，会将 FlowFiles 路由到此关系
table not found	当源表不存在时，会将 FlowFiles 路由到此关系

写入属性¶

名称	描述
mime.type	application/json
dbms.type	存储源表的数据库管理系统 (DBMS) 的类型。例如 `POSTGRESQL`
primary.key.count	源表中主键的数量
column.count	源表中的列数