State Processor API:如何讀取,寫入和修改 Flink 應用程序的狀態

過去無論您是在生產中使用,還是調研Apache Flink,估計您總是會問這樣一個問題:我該如何訪問和更新Flink保存點(savepoint)中保存的state?不用再詢問了,Apache Flink 1.9.0引入了狀態處理器(State Processor)API,它是基於DataSet API的強大擴展,允許讀取,寫入和修改Flink的保存點和檢查點(checkpoint)中的狀態。 在這
相關文章
相關標籤/搜索