Flink---鍵控狀態(keyed state)

鍵控狀態是根據輸入數據流中定義的鍵(key)來維護和訪問的。Flink 爲每個鍵值維護一個狀態實例,並將具有相同鍵的所有數據,都分區到同一個算子任務中,這個任務會維護和處理這個 key 對應的狀態。當任務處理一條數據時,它會自動將狀態的訪問範圍限定爲當前數據的 key。因此,具有相同 key 的所有數據都會訪問相同的狀態。Keyed State 很類似於一個分佈式的 key-value map 數
相關文章
相關標籤/搜索