org.apache.flink.graph.generator

Class GraphGeneratorUtils

java.lang.Object

org.apache.flink.graph.generator.GraphGeneratorUtils

public class GraphGeneratorUtils
extends Object

Utilities for graph generators.

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.api.java.DataSet<Vertex<org.apache.flink.types.LongValue,org.apache.flink.types.NullValue>>	vertexSequence(org.apache.flink.api.java.ExecutionEnvironment env, int parallelism, long vertexCount) Generates Vertices with sequential, numerical labels.
static <K,EV> org.apache.flink.api.java.DataSet<Vertex<K,org.apache.flink.types.NullValue>>	vertexSet(org.apache.flink.api.java.DataSet<Edge<K,EV>> edges, int parallelism) Generates vertices present in the given set of Edges.

Methods inherited from class java.lang.Object

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

Method Detail

vertexSequence

public static org.apache.flink.api.java.DataSet<Vertex<org.apache.flink.types.LongValue,org.apache.flink.types.NullValue>> vertexSequence(org.apache.flink.api.java.ExecutionEnvironment env,
                                                                                                                                          int parallelism,
                                                                                                                                          long vertexCount)

Generates Vertices with sequential, numerical labels.

Parameters:

env - the Flink execution environment.

parallelism - operator parallelism

vertexCount - number of sequential vertex labels

Returns:

DataSet of sequentially labeled vertices

vertexSet

public static <K,EV> org.apache.flink.api.java.DataSet<Vertex<K,org.apache.flink.types.NullValue>> vertexSet(org.apache.flink.api.java.DataSet<Edge<K,EV>> edges,
                                                                                                             int parallelism)

Generates vertices present in the given set of Edges.

Type Parameters:

K - label type

EV - edge value type

Parameters:

edges - source DataSet of Edges

parallelism - operator parallelism

Returns:

DataSet of discovered vertices

See Also:

Graph.fromDataSet(DataSet, DataSet, ExecutionEnvironment)