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.
