Flink Streaming狀態與容錯概述

概述 狀態函數(State Function)和操做符能夠跨單個元素/事件處理存儲數據,State是任何類型操做的關鍵構建塊。html 好比:apache 當應用程序搜索某些事件模式時,狀態(State)會存儲到當前時間爲止遇到的事件序列。 以每分鐘/小時/天維度聚合事件時,狀態(State)將保留掛起的聚合。 在流數據點上訓練機器學習模型時,狀態(State)保存當前版本的模型參數。 當須要管理
相關文章
相關標籤/搜索