Window的概念和类型。

1.Window(窗口)

Flink认为批处理是流处理的一个特例，所以Flink底层引擎是一个流式引擎，在上面实现了流处理和批处理。而Window就是从流处理到批处理的一个桥梁。简单来说，Window是一种可以把无界数据切割为有界数据块的手段。

例如，对流中的所有元素进行计数是不可能的，因为通常流是无限的(无界的)。所以，流上的聚合需要由 Window 来划定范围，比如 “计算过去5分钟” 或者 “最后100个元素的和”。 window可以是时间驱动的 (Time Window)(比如：每30秒)或者数据驱动的(Count Window)(如每100个元素)。

DataStream API提供了基于Time和Count的Window。同时，由于某些特殊的需要，DataStream API也提供了定制化的Window操作，供用户自定义Window。

2.Window的类型

Window根据类型可以分为两种。

• Tumbling Windows：滚动窗口，表示窗口内的数据没有重叠。
• Sliding Windows：滑动窗口，表示窗口内的数据有重叠。

tumbling window

sliding window

Window类型汇总如下：