flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Window on stream with timestamps ascending by key
Date Thu, 24 Mar 2016 18:04:55 GMT
If you would not be using watermarks at all, but only special events that
signal the "per key watermark", then you can simply build this on top of
"keyBy().flatMap()".

The custom operator would only be needed if you need access to the
watermarks, of the processing time trigger scheduler.

On Thu, Mar 24, 2016 at 2:18 PM, cam <charles-antoine.mathieu@corp.ovh.com>
wrote:

> Hi,
>
> I'd be happy to implement such an operator, I'm failry new to Flink so I'm
> still diving into it as fast as I can.
>
> Do you have some more insights about what to implement over
> OneInputStreamOperator ? I'm not sure if I should play with watermarks here
> or build a similar concept. How is that different from implementing the
> logic inside a FlatMap operator ?
>
> Regards,
> CAM
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Window-on-stream-with-timestamps-ascending-by-key-tp5598p5745.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

Mime
View raw message