Flink計算引擎支持狀態管理,所謂狀態管理就是在流式計算過程中將算子的中間結果保存在內存或者文件系統中,等下一個事件進入算子後可以讓當前事件的值與歷史值進行彙總累計。
flink 維護了兩種狀態:
- operator state:維護業務執行情況相關狀態
- keyed state:維護業務執行數據相關狀態
同時flink的checkpoint機制可以將狀態進行持久化,能夠做到失敗恢復,具備優秀的容錯性
關於flink狀態管理,後續學習詳細講解.....
Flink序列教程
![Flink序列教程:flink數據流上有狀態計算(07)](http://p2.ttnews.xyz/loading.gif)
flink序列教程
歡迎小夥伴們 關注+轉發 +評論區留言,發表您的觀點哦!點擊下方藍色字體 “瞭解更多” 可獲取更多資料。
閱讀更多 刀客程序員 的文章