org.apache.flink.graph.library

Class ConnectedComponents.CCMessenger<K>

java.lang.Object

org.apache.flink.graph.spargel.MessagingFunction<K,Long,Long,NullValue>

org.apache.flink.graph.library.ConnectedComponents.CCMessenger<K>

All Implemented Interfaces:

Serializable

Enclosing class:

ConnectedComponents<K,EV>

public static final class ConnectedComponents.CCMessenger<K>
extends MessagingFunction<K,Long,Long,NullValue>

Distributes the minimum ID associated with a given vertex among all the target vertices.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CCMessenger()

Method Summary

Modifier and Type	Method and Description
void	sendMessages(Vertex<K,Long> vertex) This method is invoked once per superstep for each vertex that was changed in that superstep.

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

getBroadcastSet, getDirection, getEdges, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, sendMessageTo, sendMessageToAllNeighbors

Methods inherited from class java.lang.Object

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

Constructor Detail

CCMessenger

public CCMessenger()

Method Detail

sendMessages

public void sendMessages(Vertex<K,Long> vertex)
                  throws Exception

Description copied from class: MessagingFunction

This method is invoked once per superstep for each vertex that was changed in that superstep. It needs to produce the messages that will be received by vertices in the next superstep.

Specified by:

sendMessages in class MessagingFunction<K,Long,Long,NullValue>

Parameters:

vertex - The vertex that was changed.

Throws:

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