一、測試結論：
1、會話視窗的間隔時間和水位線作用一樣，表示輸出現在時間 - 間隔時間之前所有未結算時間的資料，作用類似於水位線，但是和水位線開閉不一樣。
2、會話視窗顯示的資料是[上乙個時間 - 水位線 - 間隔時間+2ms ~ 現在的時間 - 水位線 - 間隔時間+1ms]之間的資料，注意左右都是閉區間。
二、測試資料：
設定:水位線4s：new boundedoutofordernesstimestampextractor[string](time.seconds(4))
間隔時間5s：eventtimesessionwindows.withgap(time.seconds(5))
資料如下：
Flink的滾動視窗 會話視窗 滑動視窗及其應用
flink作業中的視窗 是指一種對無限資料流設定有限資料集，從而實現了處理無線資料流的機制。視窗本身只是個劃分資料集的依據，它並不儲存資料。當我們需要在時間視窗維度上對資料進行聚合時，視窗是流處理應用中經常需要解決的問題。flink的視窗運算元為我們提供了方便易用的api，我們可以將資料流切分成乙個...
大資料基礎 Flink 視窗模型
在大多數場景下，我們需要統計的資料流都是無界的，因此我們無法等待整個資料流終止後才進行統計。通常情況下，我們只需要對某個時間範圍或者數量範圍內的資料進行統計分析 如每隔五分鐘統計一次過去一小時內所有商品的點選量 或者每發生1000次點選後，都去統計一下每個商品點選率的佔比。在 flink 中，我們使...
Flink流處理的時間視窗
對於流處理系統來說，流入的訊息是無限的，所以對於聚合或是連線等操作，流處理系統需要對流入的訊息進行分段，然後基於每一段資料進行聚合或是連線等操作。訊息的分段即稱為視窗，流處理系統支援的視窗有很多態別，最常見的就是時間視窗，基於時間間隔對訊息進行分段處理。本節主要介紹flink流處理系統支援的各種時間...