flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nsengupta <sengupta.nirma...@gmail.com>
Subject Re: Count of Grouped DataSet
Date Sun, 01 May 2016 10:48:44 GMT
Hello all,

This is how I have moved ahead with the implementation of finding count of a

*val k = envDefault
      .reduceGroup(nextGroup => {
            val asList = nextGroup.toList


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.

View raw message