Hi While using pregel API for Iterations how to figure out which super step the iteration currently in.
Regards Arun On Thu, Jul 17, 2014 at 4:24 PM, Arun Kumar <toga...@gmail.com> wrote: > Hi > > > > I am trying to implement belief propagation algorithm in GraphX using the > pragel API. > > *def* pregel[A] > > (initialMsg*:* A, > > maxIter*:* Int = *Int*.*MaxValue*, > > activeDir*:* EdgeDirection = *EdgeDirection*.*Out*) > > (vprog*:* (VertexId, VD, A) *=>* *VD*, > > sendMsg*:* EdgeTriplet[VD, ED] *=>* *Iterator*[(VertexId, A)], > > mergeMsg*:* (A, A) *=>* A) > > In this can we create messages in vprog function(From in coming messages) > and send them using sendMsg ? > > > > Regards > Arun >
