Flink 狀態管理

一.簡介 函數裏所有任務去維護並用來計算結果的數據都屬於任務的狀態。 流計算分爲無狀態和有狀態兩種情況: 無狀態計算觀察每個獨立事件,並根據最後一個事件輸出結果。 有狀態計算則會基於多個事件輸出結果。 狀態可以分爲兩類: 算子狀態(operator state)。 鍵值分區狀態(keyed state)。 state 一般指一個具體task/operator的狀態。 checkpoint表示一個F
相關文章
相關標籤/搜索