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
