大数据_Flink_Java版_数据处理_Watermark(7)在代码中的设置---Flink工作笔记0055

杰克逊爱学习

 关注

阅读 98

2022-03-21

然后我们来看代码,可以看到,首先,我们说这个dataStream,这里,数据流,我们可以直接

.assignTimestampsAndWatermarks() 这里设置waterMark

 

首先我们去看可以看到参数中,这里是AssignerWithPeriodicWatermarks这个参数.

我们可以去看一下这个参数的源码

相关推荐

大数据_Flink_Java版_数据处理_Watermark(7)_的设定原则---Flink工作笔记0056

小月亮06 111 0 0

大数据_Flink_Java版_数据处理_Watermark_概念和原理---Flink工作笔记0052

追梦人的自留地 83 0 0

大数据_Flink_Java版_数据处理_Watermark_特点和行为---Flink工作笔记0053

niboac 63 0 0

大数据_Flink_Java版_并行任务WaterMark传递测试---Flink工作笔记0064

福福福福福福福福福 36 0 0

大数据_Flink_Java版_数据处理_时间语义(3)_事件时间语义的设置---Flink工作笔记0051

一世独秀 123 0 0

大数据_Flink_Java版_数据处理_流处理API_Flink支持的数据类型---Flink工作笔记0035

扒皮狼 42 0 0

大数据_Flink_Java版_数据处理_流处理API_Transform(4)_分流---Flink工作笔记0032

柠檬的那个酸_2333 69 0 0

大数据_Flink_Java版_数据处理_时间语义(1)_时间语义概念---Flink工作笔记0049

you的日常 91 0 0

大数据_Flink_Java版_数据处理_Window_API_基本概念---Flink工作笔记0042

登高且赋 43 0 0

大数据_Flink_Java版_数据处理_时间语义(2)_时间语义的应用---Flink工作笔记0050

逸省 52 0 0

精彩评论（0）

0 0 举报