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 <smallthings1...@gmail.com>: > 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. >
