题目描述： 在Flink批处理中开发自定义Sink，实现将数据保存到MySQL中，直接读取HDFS指定目录中的单词数据即可。
效果： 通过自定义Sink实现将数据保存到MySQL中
任务要求:
1：使用Scala代码开发Flink批处理中的自定义Sink
2：避免频繁创建MySQL数据库连接
任务提示、思路分析：
1：查阅Flink相关资料，实现自定义Sink的开发
2：考虑使用OutputFormat
登录后即可发布作业，立即登录
正在编辑内容
我的作业
全部作业
未解锁课程不能发布信息~
解锁课程
在线咨询
领取优惠
免费试听
领取大纲