Re: Custom Window Assigner With Lateness

2016-11-10 Thread Aljoscha Krettek
Hi, this is not possible in the current implementation. Lateness is determined at the WindowOperator and within a Trigger you can actually check the current watermark and therefore determine if a window is late or not. Cheers, Aljoscha On Tue, 8 Nov 2016 at 17:19 Seth Wiesman wrote: > Is it pos

Custom Window Assigner With Lateness

2016-11-08 Thread Seth Wiesman
Is it possible in a custom window assigner to determine if an object has appeared after the watermark has passed? I want to have a standard event time tumbling window but custom logic for late data. From what I can tell there is no way from within the WindowAssigner interface to determine if an