At 2014-09-16 12:23:10 +0200, Yifan LI <iamyifa...@gmail.com> wrote:
> but I am wondering if there is a message(none?) sent to the target vertex(the
> rank change is less than tolerance) in below dynamic page rank implementation,
>
> def sendMessage(edge: EdgeTriplet[(Double, Double), Double]) = {
> if (edge.srcAttr._2 > tol) {
> Iterator((edge.dstId, edge.srcAttr._2 * edge.attr))
> } else {
> Iterator.empty
> }
> }
>
> so, in this case, there is a message, even is none, is still sent? or not?
No, in that case no message is sent, and if all in-edges of a particular vertex
return Iterator.empty, then the vertex will become inactive in the next
iteration.
Ankur
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
