Package | Description |
---|---|
org.apache.flink.graph | |
org.apache.flink.graph.examples | |
org.apache.flink.graph.pregel |
Modifier and Type | Method and Description |
---|---|
<M> Graph<K,VV,EV> |
Graph.runVertexCentricIteration(ComputeFunction<K,VV,EV,M> computeFunction,
MessageCombiner<K,M> combiner,
int maximumNumberOfIterations)
Runs a
VertexCentricIteration on the graph. |
<M> Graph<K,VV,EV> |
Graph.runVertexCentricIteration(ComputeFunction<K,VV,EV,M> computeFunction,
MessageCombiner<K,M> combiner,
int maximumNumberOfIterations,
VertexCentricConfiguration parameters)
Runs a
VertexCentricIteration on the graph with configuration options. |
Modifier and Type | Class and Description |
---|---|
static class |
PregelSSSP.SSSPCombiner
The messages combiner.
|
Modifier and Type | Method and Description |
---|---|
static <K,VV,EV,Message> |
VertexCentricIteration.withEdges(DataSet<Edge<K,EV>> edgesWithValue,
ComputeFunction<K,VV,EV,Message> cf,
MessageCombiner<K,Message> mc,
int maximumNumberOfIterations)
Creates a new vertex-centric iteration operator for graphs where the edges are associated with a value (such as
a weight or distance).
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.