flink基礎之window

  flink會把數據分成不同的窗口,然後進行彙總和統計。   flink的窗口分爲timeWindow, countWindow, sessionWindow, gapWindow。   timeWindow分爲基於時間的滾動窗口和滑動窗口。   舉個例子,統計每60秒的訪問量需要的就是滾動窗口;每5分鐘統計一次一個小時內的訪問量或者獲取訪問前幾的top值,這個時候就需要用到滑動窗口了。   如
相關文章
相關標籤/搜索