- All Implemented Interfaces:
- Enclosing class:
public static final class PageRank.RankMessenger<K>
Distributes the rank of a vertex among all target vertices according to
the transition probability, which is associated with an edge as the edge
- See Also:
- Serialized Form
Methods inherited from class org.apache.flink.graph.spargel.ScatterFunction
getBroadcastSet, getDirection, getEdges, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, sendMessageTo, sendMessageToAllNeighbors
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void sendMessages(Vertex<K,Double> vertex)
This method is invoked once per superstep for each vertex that was changed in that superstep.
It needs to produce the messages that will be received by vertices in the next superstep.
- Specified by:
sendMessages in class
vertex - The vertex that was changed.
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.