Hi, What I'm trying to do is the following: I want to incrementally add and delete elements to a state. If the element expires/goes out of the window, it needs to be removed from the state. I basically want the functionality of TTL, without using it, since I'm also using Queryable State and these two features can't be combined. Ofcourse I can give a "valid untill" time to each element when I'm adding it to the state using a ProcessFunction, and periodically iterate over the state to remove expired elements, but I was wondering if there is a more efficient way. For example to use a timer, which we give the element as a parameter, so that when the timer fires, x seconds after the timer was set, it can just look up the element directly and remove it. But how would I implement this?
Thanks! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
