0
点赞
收藏
分享

微信扫一扫

大数据_Flink_Java版_数据处理_事件时间语义下的窗口测试(1)---Flink工作笔记0057

秦瑟读书 2022-03-22 阅读 81

然后我们再来看:在事件时间语义下,我们来测试一下窗口,之前我们都不是用的这个EventTime对吧

之前我们用的是,processTime,处理时间对吧,也不是用的,摄入时间.

现在我们用eventTime事件时间来,进行一下窗口操作,首先我们还是用

WindowTest1_TimeWindow1这个测试类,可以看到上面

我们已经配置好了,环境是用事件时间,然后设置了自动waterMark,的周期是100毫秒.

然后我们从socket流中去读取数据.

然后我们再来看,我们拿到原始的inputStream流以后,我们这里转换成SensorReading 流

通过map方法

 

举报

相关推荐

0 条评论