【06】Flink 之 DataStream API(四):Data Sink 和 自定义Sink_scala addsink-CSDN博客

网站介绍:文章浏览阅读6.9k次。1、DataStream API(一):Data Sink1.1、Data Sink介绍sink是程序的数据输出,可以通过StreamExecutionEnvironment.addSink(sinkFunction)来为程序添加一个sink。flink提供了大量的已经实现好的sink方法,也可以自定义sink1.2、Data Sink类型writeAsText():将元素以字符串..._scala addsink