Package  Description 

org.apache.flink.graph  
org.apache.flink.graph.examples  
org.apache.flink.graph.library  
org.apache.flink.graph.spargel 
Modifier and Type  Method and Description 

<M> Graph<K,VV,EV> 
Graph.runScatterGatherIteration(ScatterFunction<K,VV,M,EV> scatterFunction,
GatherFunction<K,VV,M> gatherFunction,
int maximumNumberOfIterations)
Runs a ScatterGather iteration on the graph.

<M> Graph<K,VV,EV> 
Graph.runScatterGatherIteration(ScatterFunction<K,VV,M,EV> scatterFunction,
GatherFunction<K,VV,M> gatherFunction,
int maximumNumberOfIterations,
ScatterGatherConfiguration parameters)
Runs a ScatterGather iteration on the graph with configuration options.

Modifier and Type  Class and Description 

static class 
IncrementalSSSP.InvalidateMessenger
Initiate or propagate INVALIDATE messages.

static class 
PageRank.RankMessenger<K>
Distributes the rank of a vertex among all target vertices according to the transition
probability, which is associated with an edge as the edge value.

Modifier and Type  Class and Description 

static class 
ConnectedComponents.CCMessenger<K,VV extends Comparable<VV>>
Sends the current vertex value to all adjacent vertices.

static class 
LabelPropagation.SendNewLabelToNeighbors<K,VV extends Comparable<VV>>
Sends the vertex label to all outneighbors.

static class 
SingleSourceShortestPaths.MinDistanceMessenger<K>
Distributes the minimum distance associated with a given vertex among all the target vertices
summed up with the edge's value.

Modifier and Type  Method and Description 

static <K,VV,Message,EV> 
ScatterGatherIteration.withEdges(DataSet<Edge<K,EV>> edgesWithValue,
ScatterFunction<K,VV,Message,EV> sf,
GatherFunction<K,VV,Message> gf,
int maximumNumberOfIterations)
Creates a new scattergather iteration operator for graphs where the edges are associated
with a value (such as a weight or distance).

Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.