Timers and state
Posted by
Alberto Mancini on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Timers-and-state-tp18683.html
Hello,
in a Flink application we have a keyed operator that keeps a map state (MapState<UK, UV>). Some of the elements in the state need a timeout so we use a Timer.
When the timer is called the state is scoped to the key as expected but we would like to 'pass' (or have available elsewhere) to onTimer the map-key that is expiring.
The actual approach is to visit the whole map and select the correct key keeping in the map-values the expected timestamp of the timer but this seems overkill.
Is there consolidated a better approach we do not see?
Thanks,
Alberto.