Re: Allowed Lateness and Window State

2016-10-13 Thread swiesman
Thank makes perfect sense, thank you so much for your quick response Kostas! Seth Wiesman -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Allowed-Lateness-and-Window-State-tp9529p9535.html Sent from the Apache Flink User Mailing List

Re: Allowed Lateness and Window State

2016-10-13 Thread Kostas Kloudas
state will be purged). So your trigger does not need to worry about that. I hope this answers your question. Cheers, Kostas > On Oct 13, 2016, at 4:16 PM, swiesman <swies...@mediamath.com> wrote: > > Hi all, > > I have a question about allowed lateness semantics and

Allowed Lateness and Window State

2016-10-13 Thread swiesman
Hi all, I have a question about allowed lateness semantics and window state. I have a custom event time trigger that does an early FIRE onElement for a certain set of conditions and then a FIRE_AND_PURGE onEventTime. And this has worked great for me. However I now want to add a certain