public static final class LabelPropagation.SendNewLabelToNeighbors<K,VV extends Comparable<VV>> extends ScatterFunction<K,VV,VV,NullValue> implements ResultTypeQueryable<VV>
Constructor and Description |
---|
SendNewLabelToNeighbors(TypeInformation<VV> typeInformation) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<VV> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
void |
sendMessages(Vertex<K,VV> vertex)
This method is invoked once per superstep for each vertex that was changed in that superstep.
|
getBroadcastSet, getDirection, getEdges, getInDegree, getIterationAggregator, getNumberOfVertices, getOutDegree, getPreviousIterationAggregate, getSuperstepNumber, postSuperstep, preSuperstep, sendMessageTo, sendMessageToAllNeighbors
public SendNewLabelToNeighbors(TypeInformation<VV> typeInformation)
public void sendMessages(Vertex<K,VV> vertex)
ScatterFunction
sendMessages
in class ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,NullValue>
vertex
- The vertex that was changed.public TypeInformation<VV> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<VV extends Comparable<VV>>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.