org.apache.flink.graph.library

Class CommunityDetection.VertexLabelUpdater<K>

java.lang.Object

org.apache.flink.graph.spargel.VertexUpdateFunction<K,Tuple2<Long,Double>,Tuple2<Long,Double>>

org.apache.flink.graph.library.CommunityDetection.VertexLabelUpdater<K>

All Implemented Interfaces:

Serializable

Enclosing class:

CommunityDetection<K>

public static final class CommunityDetection.VertexLabelUpdater<K>
extends VertexUpdateFunction<K,Tuple2<Long,Double>,Tuple2<Long,Double>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
VertexLabelUpdater(Double delta)

Method Summary

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

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

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

VertexLabelUpdater

public VertexLabelUpdater(Double delta)

Method Detail

updateVertex

public void updateVertex(Vertex<K,Tuple2<Long,Double>> vertex,
                         MessageIterator<Tuple2<Long,Double>> inMessages)
                  throws Exception

Description copied from class: VertexUpdateFunction

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 VertexUpdateFunction.setNewVertexValue(Object). If the vertex state is changed, it will trigger the sending of messages via the MessagingFunction.

Specified by:

updateVertex in class VertexUpdateFunction<K,Tuple2<Long,Double>,Tuple2<Long,Double>>

Parameters:

vertex - The vertex.

inMessages - The incoming messages to this vertex.

Throws:

Exception - The computation may throw exceptions, which causes the superstep to fail.