Flink會話窗口測試
一、測試結論:
1、會話窗口的間隔時間和水位線作用一樣,表示輸出現在時間 - 間隔時間之前所有未結算時間的數據,作用類似於水位線,但是和水位線開閉不一樣。
2、會話窗口顯示的數據是[上一個時間 - 水位線 - 間隔時間+2ms ~ 現在的時間 - 水位線 - 間隔時間+1ms]之間的數據,注意左右都是閉區間。
二、測試數據:
設定:
水位線4s:new BoundedOutOfOrdernessTimestampExtractor[String](Time.seconds(4))
間隔時間5s:EventTimeSessionWindows.withGap(Time.seconds(5))
數據如下: