总览

简介

Extract 节点列表是一组基于 Apache Flink® 的 Source Connectors 用于从不同的源系统抽取数据。

支持的 Extract 节点列表

支持的 Flink 版本列表

下表展示了 InLong® Extract 节点 和 Flink® 版本之间的对应关系。

SQL API 用法

• 部署 InLong Sort
• 创建数据节点

下面例子展示了如何在 Flink SQL Client 创建 MySQL Extract 节点，并从中查询数据：

-- 创建一个 MySQL Extract 节点
CREATE TABLE mysql_extract_node (
 id INT NOT NULL,
 name STRING,
 age INT,
 weight DECIMAL(10,3),
 PRIMARY KEY(id) NOT ENFORCED
) WITH (
 'connector' = 'mysql-cdc-inlong',
 'hostname' = 'YourHostname',
 'port' = '3306',
 'username' = 'YourUsername',
 'password' = 'YourPassword',
 'database-name' = 'YourDatabaseName',
 'table-name' = 'YourTableName'
);
SELECT id, name, age, weight FROM mysql_extract_node;