- Flink支持兩種劃分窗口的方式，按照time和count。
如果根據時間劃分窗口，那么它就是一個time-window如果根據數據劃分窗口，那么它就是一個count-window。
- flink支持窗口的兩個重要屬性（size和interval） 如果size=interval,那么就會形成tumbling-window(無重疊數據)如果size>interval,那么就會形成sliding-window(有重疊數據)如果size< interval, 那么這種窗口將會丟失數據。
比如每5秒鐘，統計過去3秒的通過路口汽車的數據，將會漏掉2秒鐘的數據。
通過組合可以得出四種基本窗口：
- time-tumbling-window 無重疊數據的時間窗口，設置方式舉例：timeWindow(Time.seconds(5))
- time-sliding-window 有重疊數據的時間窗口，
設置方式舉例：timeWindow(Time.seconds(5), Time.seconds(3))
- count-tumbling-window無重疊數據的數量窗口
設置方式舉例：countWindow(5)
- count-sliding-window 有重疊數據的數量窗口
設置方式舉例：countWindow(5,3)
京公網安備 11010802030320號