You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/11/18 15:58:52 UTC

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

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

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

Posted by hailongwang <18...@163.com>.

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




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