Flink狀態計算實例與狀態數據恢復(checkpoint)

狀態計算,簡單的理解是本次計算依賴於以前的計算結果,好比,根據key計算求和值,如:html key  value 1001,3000-------------(1001,3000) 1002,500--------------(1002,500) 1001,400--------------(1001,3400) 其中計算第三條數據1001,400時須要累加到以前已經計算好的1001,30
相關文章
相關標籤/搜索