1 个回答
配置示例如下:
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属地:
我来回答
您需要 登录 后回答此问题!