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

Reply via email to