public static final class LabelPropagation.UpdateVertexLabel<K,VV extends Comparable<VV>> extends GatherFunction<K,VV,VV>
Constructor and Description |
---|
UpdateVertexLabel() |
Modifier and Type | Method and Description |
---|---|
void |
updateVertex(Vertex<K,VV> vertex,
MessageIterator<VV> inMessages)
This method is invoked once per vertex per superstep.
|
getBroadcastSet, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, setNewVertexValue
public void updateVertex(Vertex<K,VV> vertex, MessageIterator<VV> inMessages)
GatherFunction
GatherFunction.setNewVertexValue(Object)
. If the vertex
state is changed, it will trigger the sending of messages via the ScatterFunction
.updateVertex
in class GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>>
vertex
- The vertex.inMessages
- The incoming messages to this vertex.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.