Apache Flink 漫談系列(04) - State

實際問題 在流計算場景中,數據會源源不斷的流入Apache Flink系統,每條數據進入Apache Flink系統都會觸發計算。如果我們想進行一個Count聚合計算,那麼每次觸發計算是將歷史上所有流入的數據重新新計算一次,還是每次計算都是在上一次計算結果之上進行增量計算呢?答案是肯定的,Apache Flink是基於上一次的計算結果進行增量計算的。那麼問題來了: "上一次的計算結果保存在哪裏,保
相關文章
相關標籤/搜索