Flink會話窗口測試


Flink會話窗口測試

一、測試結論:

1、會話窗口的間隔時間和水位線作用一樣,表示輸出現在時間 - 間隔時間之前所有未結算時間的數據,作用類似於水位線,但是和水位線開閉不一樣。

2、會話窗口顯示的數據是[上一個時間 - 水位線 - 間隔時間+2ms ~ 現在的時間 - 水位線 - 間隔時間+1ms]之間的數據,注意左右都是閉區間。

 

二、測試數據:

設定:

水位線4s:new BoundedOutOfOrdernessTimestampExtractor[String](Time.seconds(4))

間隔時間5s:EventTimeSessionWindows.withGap(Time.seconds(5))

數據如下:

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM