org.apache.flink.graph.library

Class LabelPropagation.UpdateVertexLabel<K,VV extends Comparable<VV>>

java.lang.Object

org.apache.flink.graph.spargel.GatherFunction<K,VV,VV>

org.apache.flink.graph.library.LabelPropagation.UpdateVertexLabel<K,VV>

All Implemented Interfaces:

Serializable

Enclosing class:

LabelPropagation<K,VV extends Comparable<VV>,EV>

public static final class LabelPropagation.UpdateVertexLabel<K,VV extends Comparable<VV>>
extends GatherFunction<K,VV,VV>

Function that updates the value of a vertex by adopting the most frequent label among its in-neighbors.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UpdateVertexLabel()

Method Summary

Modifier and Type	Method and Description
void	updateVertex(Vertex<K,VV> vertex, MessageIterator<VV> inMessages) This method is invoked once per vertex per superstep.

Methods inherited from class org.apache.flink.graph.spargel.GatherFunction

getBroadcastSet, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, setNewVertexValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UpdateVertexLabel

public UpdateVertexLabel()

Method Detail

updateVertex

public void updateVertex(Vertex<K,VV> vertex,
                         MessageIterator<VV> inMessages)

Description copied from class: GatherFunction

This method is invoked once per vertex per superstep. It receives the current state of the vertex, as well as the incoming messages. It may set a new vertex state via GatherFunction.setNewVertexValue(Object). If the vertex state is changed, it will trigger the sending of messages via the ScatterFunction.

Specified by:

updateVertex in class GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>>

Parameters:

vertex - The vertex.

inMessages - The incoming messages to this vertex.