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

プロパティ¶

プロパティ	説明
列フィルターサービス	不要な列のフィルタリングに使用する列フィルターサービスを指定します。
接続プール	ソース・テーブル・スキーマの取得に使用する接続プール。
スキーマ名	ソース・テーブルが格納されているスキーマの名前。
テーブル名	ソース・テーブルの名前

リレーションシップ¶

名前	説明
failure	FlowFiles は、ソース・テーブルのスキーマを取得できないイベントのために、このリレーションにルーティングされます。
success	FlowFiles は、ソーステーブルのスキーマが正常にフェッチされると、このリレーションにルーティングされます。
テーブルが見つかりません	FlowFiles ソーステーブルが存在しない場合、このリレーションにルーティングされます。

属性の書き込み¶

名前	説明
mime.type	application/json
dbms.type	ソース・テーブルが格納されているデータベース管理システム (DBMS) のタイプ。例: `POSTGRESQL`
primary.key.count	ソース・テーブルのプライマリ・キーの数。
column.count	ソーステーブルの列数