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 <[email protected]> wrote: > 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 > element arrived after the watermark. Is this currently possible to do in > flink? > > > > Thank you, > > > > Seth Wiesman >
