Hi, Andrey

I think ttl state has another scenario to simulate the slide window with the
process function. User can define a state to store the data with the latest
1 day. And trigger calculate on the state every 5min. It is a operator
similar to slidewindow. But i think it is more efficient than the
slidewindow because it dont have to store the redundant data and the expire
data can be delete automatic. 

However with the support of ttl state based on processing time we can just
implement the processing slide window. If we can support ttl based on event
time I think we can expand this capacity.

So in this scenario, the event-time-accesstime/watermark-expiration-check
will be the proper combination. 

I think if can add the interface to allow user to custom will be flexible. 

Thanks,
Aitozi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to