public class CirculantGraph extends GraphGeneratorBase<LongValue,NullValue,NullValue>
Modifier and Type | Class and Description |
---|---|
static class |
CirculantGraph.OffsetRange
Stores the start offset and length configuration for an offset range.
|
Modifier and Type | Field and Description |
---|---|
static int |
MINIMUM_OFFSET |
static int |
MINIMUM_VERTEX_COUNT |
parallelism
Constructor and Description |
---|
CirculantGraph(ExecutionEnvironment env,
long vertexCount)
An oriented
Graph with n vertices where each vertex
vi is connected to vertex v(i+j)%n for each
configured offset j . |
Modifier and Type | Method and Description |
---|---|
CirculantGraph |
addRange(long offset,
long length)
Required configuration for each range of offsets in the graph.
|
Graph<LongValue,NullValue,NullValue> |
generate()
Generates the configured graph.
|
setParallelism
public static final int MINIMUM_VERTEX_COUNT
public static final int MINIMUM_OFFSET
public CirculantGraph(ExecutionEnvironment env, long vertexCount)
Graph
with n
vertices where each vertex
vi is connected to vertex v(i+j)%n for each
configured offset j
.env
- the Flink execution environmentvertexCount
- number of verticespublic CirculantGraph addRange(long offset, long length)
offset
- first offset appointing the vertices' positionlength
- number of contiguous offsets in rangepublic Graph<LongValue,NullValue,NullValue> generate()
GraphGenerator
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.