然后我们来看代码,可以看到,首先,我们说这个dataStream,这里,数据流,我们可以直接
.assignTimestampsAndWatermarks() 这里设置waterMark
首先我们去看可以看到参数中,这里是AssignerWithPeriodicWatermarks这个参数.
我们可以去看一下这个参数的源码
大数据_Flink_Java版_数据处理_Watermark(7)在代码中的设置---Flink工作笔记0055
猜你喜欢
转载自blog.csdn.net/lidew521/article/details/123482595
今日推荐
周排行