flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Anderson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend
Date Mon, 25 Sep 2017 19:17:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16179607#comment-16179607
] 

David Anderson commented on FLINK-7683:
---------------------------------------

Something like this has also been requested by users managing state for very large numbers
of keys, who would rather occasionally iterate over all their state and clear expired items,
rather than having a timer per key. Will that become possible?

> Add method to iterate over all of the existing keys in a statebackend
> ---------------------------------------------------------------------
>
>                 Key: FLINK-7683
>                 URL: https://issues.apache.org/jira/browse/FLINK-7683
>             Project: Flink
>          Issue Type: New Feature
>          Components: State Backends, Checkpointing
>            Reporter: Piotr Nowojski
>            Assignee: Piotr Nowojski
>
> This is required to make possible preserving backward compatibility while changing state
definition of a keyed state operator (to do so operator must iterate over all of the existing
keys and rewrites them into a new state variable).



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message