上面我们已经使用了自定义数据源和Flink自带的Kafka源，那么接下来就模拟着写一个从MySQL中读取数据的源。

示范

自定义数据源, 读取MySql数据库(test)表(user)数据

建表语句

相关依赖

开发步骤

• 自定义Source，继承自定义RichSourceFunction

• 实际开放方法

• 实际运行方法

• 加载驱动

• 创建连接

• 创建PreparedStatement

• 执行查询

• 遍历查询结果,收集数据

• 使用自定义来源

• 打印结果

• 执行任务

参考代码