本文主要是介绍Flink实例(六十七):自定义时间和窗口的操作符(十二)Flink事件时间何时触发窗口计算,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
思考:
什么时候才会触发窗口计算?
既然使用的是事件时间那么必然会涉及到水位线(water_mark),水位线在其中扮演的角色是什么?
此时我们带着疑问,一步一步的探究
注意:本篇博客中的所有解释都是在滚动窗口的前提下
Q:为什么要在滚动窗口的前提下进行解释?
A:因为滚动窗口相比较滑动和会话来说更容易让大家理解,在本篇博客中着重的是讨论水位线在窗口触发下的场景,因此当然采用大家较容易理解的窗口来为大家解释。
Q:那我要是想了解水位线在其他窗口下的场景呢?
A:在本栏的其他博客有详细介绍。
1.1 浏览本博客前你需要了解的知识点
flink内部是如何划分窗口的?
首先Windows的时间范围是一个自然时间范围,比如你定义了一个窗口:timeWindow(Time.seconds(3));那么其windows会将窗口中的事件按照3S进行划分(左闭右开)
[10:11:00,10:11:03)
[10:11:03,10:11:06)<
这篇关于Flink实例(六十七):自定义时间和窗口的操作符(十二)Flink事件时间何时触发窗口计算的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!