流式計算-low watermark機制

前言 最近在學習流式計算相關的知識，在閱讀了MillWheel論文，在這裏對low watermark機制做一個總結與介紹。 Window 實時數據流是永不停歇的，我們無法獲取所有的數據併產出一個最終的結果。很多情況下我們更關心的是最近的狀態，而不是從實時數據流啓動至今的統計數據。因此需要將數據流切分爲一個個片段，這些片段形象的稱爲Window。總而言之，Window是將無邊界的實時數據流進行劃分

>>阅读原文<<