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.VertexDistanceUpdater
When an INVALIDATE message indicates that the only shortest path
containing this vertex has been removed then set the vertex distance to
infinity.
|
static class |
PageRank.VertexRankUpdater<K>
Function that updates the rank of a vertex by summing up the partial
ranks from all incoming messages and then applying the dampening formula.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.CCUpdater<K,VV extends Comparable<VV>>
Updates the value of a vertex by picking the minimum neighbor value out of all the incoming messages.
|
static class |
LabelPropagation.UpdateVertexLabel<K,VV extends Comparable<VV>>
Function that updates the value of a vertex by adopting the most frequent
label among its in-neighbors.
|
static class |
SingleSourceShortestPaths.VertexDistanceUpdater<K>
Function that updates the value of a vertex by picking the minimum
distance from all incoming messages.
|
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 scatter-gather iteration operator for graphs where the edges are associated with a value (such as
a weight or distance).
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.