开发参考

可参考官方 JDBC Connector 的实现。

注意：开发时 pom.xml 中相关的 flink 依赖需要添加<scope>provided</scope>

平台上使用

1. 在平台的文件依赖中添加 connector 打的 jar 包文件。
2. 在sql的配置中：'connector'='XXX'(在 DynamicTableFactory 中定义的 identifier)

-- register a Custom table in Flink SQL
CREATE TABLE MyUserTable (
  id BIGINT,
  name STRING,
  age INT,
  status BOOLEAN,
  PRIMARY KEY (id) NOT ENFORCED
) WITH (
   'connector' = '***'
);