如何加载mysql数据到flink任务内存

[ゞ野蠻遊戲χ]

大家好！      如何使用DataStream在任务初始化时候加载mysql数据到flink任务的内存中，请给我一个demo。
谢谢，
jiazhi

[hailongwang]

Hi,
你需要继承 RichFunction，然后实现下 open 方法。
其中在 open 方法里面需要，
1. 建立 Mysql 连接
2. 获得 PreparedStatement 对象
3. 根据 SQL 获得 ResultSet
4. 遍历 ResultSet load 在内存中
5. 释放连接资源




在 2020-11-18 22:58:52，"ゞ野蠻遊戲χ" <[hidden email]> 写道：
>大家好！&nbsp; &nbsp; &nbsp;&nbsp;如何使用DataStream在任务初始化时候加载mysql数据到flink任务的内存中，请给我一个demo。
>谢谢，
>jiazhi