@somanath Sankaran:
是的,自定義狀態函數mapGroupsWithState和applyInPandasWithState使用相同的狀態存儲內置的聚合狀態存儲。默認情況下,這個狀態存儲在RocksDB,嵌入式,持續優化的鍵值存儲大量數據的存儲和檢索。
國家由磚運行時存儲管理和自動分布在工人集群中的節點。這使得國家共享和更新多個任務並行運行。國家也容錯和可以恢複一個節點故障。
當使用自定義狀態功能,重要的是要記住,維護的狀態函數的數量可以產生重大影響集群性能和內存使用。重要的是要正確配置狀態超時和拆遷政策,確保老,未使用的狀態是定期清理,以避免耗盡內存。
