(20) flink有狀態的算子和應用程序

文章目錄 算子狀態(operator state) 鍵控狀態(Keyed State) Flink內置的很多算子,數據源source,數據存儲sink都是有狀態的,流中的數據都是buffer records,會保存一定的元素或者元數據。例如: ProcessWindowFunction會緩存輸入流的數據,ProcessFunction會保存設置的定時器信息等等。 在Flink中,狀態始終與特定算子
相關文章
相關標籤/搜索