CaptureChangeMySQL 2025.10.2.19¶

バンドル¶

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

説明¶

Reads CDC events from a MySQL database. The processor continuously reads events from binary log files, filtering those related to the tables provided by the TableStateService, and discarding the rest. The processor outputs two types of FlowFiles: - DDLs containing the schema of a table (the initial schema and a new schema on every schema change). - DMLs with records representing changes to the data in the table. One FlowFile always represents data related to a single table. The DDL with the schema is written to the FlowFile content as a JSON object: { "columns": [ { "name": "<columnName>", "type": "<snowflakeType>", "nullable": <true|false>, "scale": <scale>, "precision": <precision> }, ... ], "primaryKeys": ["<primaryKey1>", "<primaryKey2>", ...] } Structure of the FlowFiles containing the DML records: { "primaryKeys": { "<column>": <value>, ... }, "payload": { "<column>": <value>, ... }, "metadata": { "<column>": <value>, ... }

タグ¶

cdc, event, jdbc, mysql, sql

入力要件¶

FORBIDDEN

機密動的プロパティをサポート¶

false

プロパティ¶

状態管理¶

リレーションシップ¶

属性の書き込み¶