Re: Count Different Codes in a Window

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Count-Different-Codes-in-a-Window-tp14391p14416.html

Hi Raj,

You can use ReduceFunction in combination with a WindowFunction [1].

Best, Fabian

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html#windowfunction-with-incremental-aggregation

2017-07-24 20:31 GMT+02:00 Raj Kumar <[hidden email]>:

Thanks Fabian. That helped.

But I want to access the window start time. AFAIK, reduce can not give this
details as it doesn't have timewindow object passed to the reduce method.
How can I achieve this ?



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Count-Different-Codes-in-a-Window-tp14391p14414.html

Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.