public static final class PregelSSSP.SSSPComputeFunction extends ComputeFunction<Long,Double,Double,Double>
Constructor and Description |
---|
SSSPComputeFunction(long src) |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<Long,Double> vertex,
MessageIterator<Double> messages)
This method is invoked once per superstep, for each active vertex.
|
getBroadcastSet, getEdges, getIterationAggregator, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, sendMessageTo, sendMessageToAllNeighbors, setNewVertexValue
public void compute(Vertex<Long,Double> vertex, MessageIterator<Double> messages)
ComputeFunction
This method can iterate over all received messages, set the new vertex value, and send messages to other vertices (which will be delivered in the next superstep).
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.