网站介绍:文章浏览阅读6.9k次。1、DataStream API(一):Data Sink1.1、Data Sink介绍sink是程序的数据输出,可以通过StreamExecutionEnvironment.addSink(sinkFunction)来为程序添加一个sink。flink提供了大量的已经实现好的sink方法,也可以自定义sink1.2、Data Sink类型writeAsText():将元素以字符串..._scala addsink
- 链接地址:https://blog.csdn.net/hongzhen91/article/details/90146906
- 链接标题:【06】Flink 之 DataStream API(四):Data Sink 和 自定义Sink_scala addsink-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:1872
- 网站标签:scala addsink