全部产品

Flink ADB Connector

更新时间:2020-07-30 14:04:36

本文以示例形式介绍如何将开源Flink中的数据写入到ADB。

操作步骤

  1. 下载flink-jdbc-adb-compatibility_2.11-1.10.10.jar

  2. 将所有Flink节点/home/admin/flink-1.10.1/lib下的flink-jdbc_2.11-1.10.1.jar文件替换为flink-jdbc-adb-compatibility_2.11-1.10.10.jar 。

  3. 重启所有Flink节点。

  4. 在Flink中创建ADB表。

    CREATE TABLE table_test (
     col1 VARCHAR,
     col2 BIGINT,
     col3 BIGINT
    ) WITH (
     'connector.type' = 'jdbc', -- 使用 jdbc connector
     'connector.dialect' = 'adb', -- 使用connector dialect
     'connector.url' = 'jdbc:mysql://ip:port/db_name', -- jdbc url
     'connector.table' = 'table_name', -- 表名
     'connector.username' = 'xxx', -- ADB账号名
     'connector.password' = 'xxx', -- ADB账号名对应的密码
    );

    更多Flink信息,请参见Flink