Excellent thanks Ankur, looks like what im looking for Only one problem the line
val dists = initDists.pregel[DistanceMap](Map())(vprog, sendMsg, mergeMsg) produces an error Job aborted: Task 268.0:5 had a not serializable result: java.io.NotSerializableException: scala.collection.immutable.MapLike$$anon$2 any ideas? thanks -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/counting-degrees-graphx-tp6370p6405.html Sent from the Apache Spark User List mailing list archive at Nabble.com.
