Hello all, This is how I have moved ahead with the implementation of finding count of a GroupedDataSet:
*val k = envDefault .fromElements((1,1,2,"A"),(1,1,2,"B"),(2,1,3,"B"),(3,1,4,"C")) .groupBy(1,2) .reduceGroup(nextGroup => { val asList = nextGroup.toList (asList.head._2,asList.head._3,asList.size) }) k.print()* While this produces the expected output alright, I am not sure if this the ideal, idiomatic way to implement what I need. Could you please confirm? If there is a better way, I would like to be wiser of course. -- Nirmalya -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Count-of-Grouped-DataSet-tp6592p6594.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.