FlinkSQL中的JDBC Connector如何配置和使用?

提问者:帅平 问题分类:大数据
FlinkSQL中的JDBC Connector如何配置和使用?
1 个回答
披起头发是娇弱
披起头发是娇弱
配置示例如下:
1、添加依赖
<!-- Maven示例 -->
<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>8.0.28</version>
</dependency>
2、创建jdbc表
CREATE TABLE jdbc_table (
  id INT,
  name STRING,
  order_time TIMESTAMP(3),
  WATERMARK FOR order_time AS order_time - INTERVAL '5' SECOND
) WITH (
  'connector' = 'jdbc',
  'url' = 'jdbc:mysql://localhost:3306/mydb',
  'table-name' = 'orders',
  'username' = 'root',
  'password' = '123456',
  'scan.fetch-size' = '1000',       -- 批量读取大小
  'scan.partition-column' = 'id',   -- 分区列(用于并行读取)
  'scan.partition-count' = '4'      -- 并行度
);
发布于:3周前 (05-28) IP属地:
我来回答