org.apache.flink.graph.library

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

java.lang.Object

org.apache.flink.graph.spargel.ScatterFunction<K,VV,VV,org.apache.flink.types.NullValue>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<VV>

Enclosing class:

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

public static final class LabelPropagation.SendNewLabelToNeighbors<K,VV extends Comparable<VV>>
extends ScatterFunction<K,VV,VV,org.apache.flink.types.NullValue>
implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<VV>

Sends the vertex label to all out-neighbors.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SendNewLabelToNeighbors(org.apache.flink.api.common.typeinfo.TypeInformation<VV> typeInformation)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.typeinfo.TypeInformation<VV>	getProducedType()
void	sendMessages(Vertex<K,VV> 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.ScatterFunction

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

SendNewLabelToNeighbors

public SendNewLabelToNeighbors(org.apache.flink.api.common.typeinfo.TypeInformation<VV> typeInformation)

Method Detail

sendMessages

public void sendMessages(Vertex<K,VV> vertex)

Description copied from class: ScatterFunction

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 ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,org.apache.flink.types.NullValue>

Parameters:

vertex - The vertex that was changed.

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<VV> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<VV extends Comparable<VV>>