Flink狀態管理和容錯機制介紹

本文主要內容如下: 有狀態的流數據處理; Flink中的狀態接口; 狀態管理和容錯機制實現; 阿里相關工作介紹; 一.有狀態的流數據處理# 1.1.什麼是有狀態的計算# 計算任務的結果不僅僅依賴於輸入,還依賴於它的當前狀態,其實大多數的計算都是有狀態的計算。 比如wordcount,給一些word,其計算它的count,這是一個很常見的業務場景。count做爲輸出,在計算的過程中要不斷的把輸入累加
相關文章
相關標籤/搜索