GroupedDataset collect

[Maximilian Alber]

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