在本站之前的文章也介绍过相关的自定义sink,可参考《Flink学习系列(七)自定义实现一个flink的mysqlsink》。在实际使用过程中,我们只需要调用addsink方法把定义的sink添加进来即可。
正文
Flink应用开发系列(二十九)DataStream开发之自定义sink
不要总是纠结于过去的人和事,而使自己陷入长久的悲伤中,你要努力的放下执念,顺着自己的心意活着。往后余生,愿你不念过往,不畏将来,笑对生活中的风风雨雨,任凭时光荏苒,每一天都是自己喜欢的模样。
-- 展开阅读全文 --
还没有评论,来说两句吧...