org.apache.flink.graph.pregel

Class VertexCentricConfiguration

java.lang.Object

org.apache.flink.graph.IterationConfiguration

org.apache.flink.graph.pregel.VertexCentricConfiguration

public class VertexCentricConfiguration
extends IterationConfiguration

A VertexCentricConfiguration object can be used to set the iteration name and degree of parallelism, to register aggregators and use broadcast sets in the ComputeFunction.

The VertexCentricConfiguration object is passed as an argument to ( org.apache.flink.graph.pregel.ComputeFunction, int, VertexCentricConfiguration).

Constructor Summary

Constructors

Constructor and Description
VertexCentricConfiguration()

Method Summary

Modifier and Type	Method and Description
void	addBroadcastSet(String name, DataSet<?> data) Adds a data set as a broadcast set to the compute function.
List<Tuple2<String,DataSet<?>>>	getBcastVars() Get the broadcast variables of the compute function.

Methods inherited from class org.apache.flink.graph.IterationConfiguration

getAggregators, getName, getParallelism, isOptNumVertices, isSolutionSetUnmanagedMemory, registerAggregator, setName, setOptNumVertices, setParallelism, setSolutionSetUnmanagedMemory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VertexCentricConfiguration

public VertexCentricConfiguration()

Method Detail

addBroadcastSet

public void addBroadcastSet(String name,
                            DataSet<?> data)

Adds a data set as a broadcast set to the compute function.

Parameters:

name - The name under which the broadcast data set is available in the compute function.

data - The data set to be broadcast.

getBcastVars

public List<Tuple2<String,DataSet<?>>> getBcastVars()

Get the broadcast variables of the compute function.

Returns:

a List of Tuple2, where the first field is the broadcast variable name and the second field is the broadcast data set.