Package org.apache.flink.examples.java.graph.util

Class ConnectedComponentsData

java.lang.Object

org.apache.flink.examples.java.graph.util.ConnectedComponentsData

public class ConnectedComponentsData
extends Object

Provides the default data sets used for the Connected Components example program. The default data sets are used, if no parameters are given to the program.

Field Summary

Fields

Modifier and Type	Field	Description
static Object[][]	EDGES
static long[]	VERTICES

Constructor Summary

Constructors

Constructor	Description
ConnectedComponentsData()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple2<Long,Long>>	getDefaultEdgeDataSet(org.apache.flink.api.java.ExecutionEnvironment env)
static org.apache.flink.api.java.DataSet<Long>	getDefaultVertexDataSet(org.apache.flink.api.java.ExecutionEnvironment env)

Methods inherited from class java.lang.Object

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

Field Detail

VERTICES

public static final long[] VERTICES

EDGES

public static final Object[][] EDGES

Constructor Detail

ConnectedComponentsData

public ConnectedComponentsData()

Method Detail

getDefaultVertexDataSet

public static org.apache.flink.api.java.DataSet<Long> getDefaultVertexDataSet(org.apache.flink.api.java.ExecutionEnvironment env)

getDefaultEdgeDataSet

public static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple2<Long,Long>> getDefaultEdgeDataSet(org.apache.flink.api.java.ExecutionEnvironment env)