GroupedDataset collect

Posted by Maximilian Alber on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/GroupedDataset-collect-tp1607.html

Hi Flinksters,

I tried to call collect on a grouped data set, somehow it did not work. Is this intended? If yes, why?

Code snippet:
    // group a data set according to second field:
    val grouped_ds = cross_ds.groupBy(1)
    println("After groupBy: "+grouped_ds.collect())

Error:

[ant:scalac] /media/alber/datadisk/tmp/flink/code/test/src/main/scala/test.scala:107: error: value collect is not a member of org.apache.flink.api.scala.GroupedDataSet[(Int, Int)]
[ant:scalac]     println("After groupBy: "+grouped_ds.collect())
[ant:scalac]                                          ^
[ant:scalac] one error found

Thanks!

Cheers,

Max