Re: MapState.entries()

2022-03-08 Thread Alexey Trenikhun
Thank you ! From: Schwalbe Matthias Sent: Monday, March 7, 2022 11:36:22 PM To: Alexey Trenikhun ; Flink User Mail List Subject: RE: MapState.entries() Hi Alexey, To my best knowledge it’s lazy with RocksDBStateBackend, using the Java iterator you could

RE: MapState.entries()

2022-03-07 Thread Schwalbe Matthias
Hi Alexey, To my best knowledge it's lazy with RocksDBStateBackend, using the Java iterator you could even modify the map (e.g. remove()). Cheers Thias From: Alexey Trenikhun Sent: Dienstag, 8. März 2022 06:11 To: Flink User Mail List Subject: MapState.entries() Hello, We are using

MapState.entries()

2022-03-07 Thread Alexey Trenikhun
Hello, We are using RocksDBStateBackend, is MapState.entries() call in this case "lazy" - deserializes single entry while next(), or MapState.entries() returns collection, which is fully loaded into memory? Thanks, Alexey