flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Custom Window Assigner With Lateness
Date Thu, 10 Nov 2016 09:34:55 GMT
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.


On Tue, 8 Nov 2016 at 17:19 Seth Wiesman <swiesman@mediamath.com> 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

View raw message