Re: Pregel Question

2016-11-22 Thread Saliya Ekanayake
Just realized the attached file has text formatting wrong. The github link to the file is https://github.com/esaliya/graphxprimer/blob/master/src/main/scala-2.10/org/saliya/graphxprimer/PregelExample2.scala On Tue, Nov 22, 2016 at 3:08 PM, Saliya Ekanayake wrote: > Hi, > > I've created a graph w

Pregel Question

2016-11-22 Thread Saliya Ekanayake
Hi, I've created a graph with vertex data of the form (Int, Array[Int]). I am using the pregel operator to update values of the array for each vertex. So my vprog has the following signature. Note the message is a map of arrays from neighbors def vprog(vertexId: VertexId, value: (Int, Array[Int]