Apache Flink 漫談系列(04) - State

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