Uses of Class
org.apache.flink.graph.spargel.ScatterFunction

Packages that use ScatterFunction

Package	Description
org.apache.flink.graph
org.apache.flink.graph.library
org.apache.flink.graph.spargel

Uses of ScatterFunction in org.apache.flink.graph

Methods in org.apache.flink.graph with parameters of type ScatterFunction

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.

Uses of ScatterFunction in org.apache.flink.graph.library

Subclasses of ScatterFunction in org.apache.flink.graph.library

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 out-neighbors.
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.

Uses of ScatterFunction in org.apache.flink.graph.spargel

Methods in org.apache.flink.graph.spargel with parameters of type ScatterFunction

Modifier and Type	Method and Description
static <K,VV,Message,EV> ScatterGatherIteration<K,VV,Message,EV>	ScatterGatherIteration.withEdges(org.apache.flink.api.java.DataSet<Edge<K,EV>> edgesWithValue, ScatterFunction<K,VV,Message,EV> sf, GatherFunction<K,VV,Message> gf, int maximumNumberOfIterations) Creates a new scatter-gather iteration operator for graphs where the edges are associated with a value (such as a weight or distance).