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
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]