Flink时间和窗口_flink 状态等待时间

目录

时间语义

水位线（Watermarks） 

并行流中的水位线

窗口

滚动窗口—Tumbling Windows

滑动窗口—Sliding Windows

会话窗口—Session Windows

 全局窗口—Global Windows

例子

---

时间语义

        如图所示，由事件生成器（Event Producer）生成事件，生成的事件数据被收集起来，首先进入分布式消息队列（Message Queue），然后被 Flink 系统中的 Source 算子（Data Source）读取消费，进而向下游的窗口算子（Window Operator）传递，最终由窗口算子进行计算处理。

​ 有两个非常重要的时间点：

（1）一个是数据产生的时刻，我们把它叫作“事件时间”（Event Time）；

（2）另一个是数据真正被Flink处理的时刻，叫作“处理时间”（Processing Time）。

我们所定义的窗口操作，到底是以哪种时间作为衡量标准，就是所谓的“时间语义”（Notions of Time）。由于分布式系统中存在网络传输延迟和时钟漂移，事件的处理时间相对发生时间会有所滞后。

事件时间（Event Time）： 指每个事件在其产生设备上发生的时间。

处理时间（Processing Time）： 是指对事件执行相应操作的机器的系统时间。