You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Alexey Trenikhun <ye...@msn.com> on 2022/03/08 05:10:44 UTC

MapState.entries()

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

Re: MapState.entries()

Posted by Alexey Trenikhun <ye...@msn.com>.

Thank you !
________________________________
From: Schwalbe Matthias <Ma...@viseca.ch>
Sent: Monday, March 7, 2022 11:36:22 PM
To: Alexey Trenikhun <ye...@msn.com>; Flink User Mail List <us...@flink.apache.org>
Subject: RE: MapState.entries()

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 <ye...@msn.com>
Sent: Dienstag, 8. März 2022 06:11
To: Flink User Mail List <us...@flink.apache.org>
Subject: MapState.entries()

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

Diese Nachricht ist ausschliesslich für den Adressaten bestimmt und beinhaltet unter Umständen vertrauliche Mitteilungen. Da die Vertraulichkeit von e-Mail-Nachrichten nicht gewährleistet werden kann, übernehmen wir keine Haftung für die Gewährung der Vertraulichkeit und Unversehrtheit dieser Mitteilung. Bei irrtümlicher Zustellung bitten wir Sie um Benachrichtigung per e-Mail und um Löschung dieser Nachricht sowie eventueller Anhänge. Jegliche unberechtigte Verwendung oder Verbreitung dieser Informationen ist streng verboten.

This message is intended only for the named recipient and may contain confidential or privileged information. As the confidentiality of email communication cannot be guaranteed, we do not accept any responsibility for the confidentiality and the intactness of this message. If you have received it in error, please advise the sender by return e-mail and delete this message and any attachments. Any unauthorised use or dissemination of this information is strictly prohibited.

RE: MapState.entries()

Posted by Schwalbe Matthias <Ma...@viseca.ch>.

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 <ye...@msn.com>
Sent: Dienstag, 8. März 2022 06:11
To: Flink User Mail List <us...@flink.apache.org>
Subject: MapState.entries()

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
Diese Nachricht ist ausschliesslich für den Adressaten bestimmt und beinhaltet unter Umständen vertrauliche Mitteilungen. Da die Vertraulichkeit von e-Mail-Nachrichten nicht gewährleistet werden kann, übernehmen wir keine Haftung für die Gewährung der Vertraulichkeit und Unversehrtheit dieser Mitteilung. Bei irrtümlicher Zustellung bitten wir Sie um Benachrichtigung per e-Mail und um Löschung dieser Nachricht sowie eventueller Anhänge. Jegliche unberechtigte Verwendung oder Verbreitung dieser Informationen ist streng verboten.

This message is intended only for the named recipient and may contain confidential or privileged information. As the confidentiality of email communication cannot be guaranteed, we do not accept any responsibility for the confidentiality and the intactness of this message. If you have received it in error, please advise the sender by return e-mail and delete this message and any attachments. Any unauthorised use or dissemination of this information is strictly prohibited.