Not able to update collections

2015-02-24 Thread kvvt
I am working on the below piece of code. var lst = scala.collection.mutable.MutableList[VertexId]() graph.edges.groupBy[VertexId](f).foreach { edgesBySrc => { lst ++= func(edgesBySrc) } } println(lst.length) Here, the final println() always says that the length of the list is 0. The li

RDD groupBy

2015-02-23 Thread kvvt
In the snippet below, graph.edges.groupBy[VertexId](f1).foreach { edgesBySrc => { f2(edgesBySrc).foreach { vertexId => { *println(vertexId)* } } } } "f1" is a function that determines how to group the edges (in my case it groups by source vertex) "f2" is another fu