flink sql 使用自定义的mysql source分片读取

最近遇到个场景，需要对大表进行 Table Scan，使用官方的 jdbc connect, 发现在执行的时候，如果表的数据量很大（百万级别），在 select 阶段会消耗大量的时间，如下：

 

任务执行了 9 分钟多，数据才上来，数据上来后，差不多一批就全部上来了

差不多 10 分钟读完，还不能通过增加并行度的方式提高读取速度

并行 mysql source 实现

在自定义的 mysql lookup source 基础上添加 TableScan 的 Source

Source 继承 RichParallelSourceFunction

1. 构造方法中接收配置参数
2. open 方法中创建 jdbc 连接，基于主键查询表中的最大值，最小值
3. run 方法中，基于任务的并行度，将数据按主键，均分给每个并行度
4. 每个并行度分批次读取分给自己的数据

MysqlOption

并行 source，最重要的是基于键，将数据均分到每个并行度；同时在读取的时候，加入了批次概念，避免一次性读取太多数据（其实是抄的 flink cdc 的概念）
MysqlOption.java

public static final Config