public static final class CommunityDetection.LabelMessenger<K> extends ScatterFunction<K,Tuple2<Long,Double>,Tuple2<Long,Double>,Double>
Constructor and Description |
---|
LabelMessenger() |
Modifier and Type | Method and Description |
---|---|
void |
sendMessages(Vertex<K,Tuple2<Long,Double>> vertex)
This method is invoked once per superstep for each vertex that was changed in that superstep.
|
getBroadcastSet, getDirection, getEdges, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, sendMessageTo, sendMessageToAllNeighbors
public void sendMessages(Vertex<K,Tuple2<Long,Double>> vertex) throws Exception
ScatterFunction
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.