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.
