org.apache.flink.graph.generator

Class GraphGeneratorBase<K,VV,EV>

java.lang.Object

org.apache.flink.graph.generator.GraphGeneratorBase<K,VV,EV>

Type Parameters:

K - graph ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphGenerator<K,VV,EV>

Direct Known Subclasses:

CirculantGraph, CompleteGraph, CycleGraph, EchoGraph, EmptyGraph, GridGraph, HypercubeGraph, PathGraph, RMatGraph, SingletonEdgeGraph, StarGraph

public abstract class GraphGeneratorBase<K,VV,EV>
extends Object
implements GraphGenerator<K,VV,EV>

Base class for graph generators.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	parallelism

Constructor Summary

Constructors

Constructor and Description
GraphGeneratorBase()

Method Summary

Modifier and Type	Method and Description
GraphGenerator<K,VV,EV>	setParallelism(int parallelism) Override the operator parallelism.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.graph.generator.GraphGenerator

generate

Field Detail

parallelism

protected int parallelism

Constructor Detail

GraphGeneratorBase

public GraphGeneratorBase()

Method Detail

setParallelism

public GraphGenerator<K,VV,EV> setParallelism(int parallelism)

Description copied from interface: GraphGenerator

Override the operator parallelism.

Specified by:

setParallelism in interface GraphGenerator<K,VV,EV>

Parameters:

parallelism - operator parallelism

Returns:

this