Hi Alberto, an ultimate solution for your problem would be a map state with ordered keys (like a TreeMap), but unfortunately, this is still a WIP feature.
For now, maybe you could "eagerly remove” the outdated value (with `iterator.remove()`) when iterating the map state in the process function or split the key space for your map state into static bins, thus you could calculate a set of outdated keys before removing them. Hope that helps. Best, Xingcan > On 5 Mar 2018, at 4:19 PM, Alberto Mancini <ab.manc...@gmail.com> wrote: > >
