public static final class CommunityDetection.LabelMessenger<K> extends MessagingFunction<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
MessagingFunction
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.