org.apache.flink.graph.examples.data

Class IncrementalSSSPData

java.lang.Object

org.apache.flink.graph.examples.data.IncrementalSSSPData

public class IncrementalSSSPData
extends Object

Provides the default data sets used for the IncrementalSSSP example program. If no parameters are given to the program, the default data sets are used.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EDGES
static String	EDGES_IN_SSSP
static int	NUM_VERTICES
static String	RESULTED_VERTICES
static String	SRC_EDGE_TO_BE_REMOVED
static String	TRG_EDGE_TO_BE_REMOVED
static String	VAL_EDGE_TO_BE_REMOVED
static String	VERTICES

Method Summary

Modifier and Type	Method and Description
static DataSet<Edge<Long,Double>>	getDefaultEdgeDataSet(ExecutionEnvironment env)
static DataSet<Edge<Long,Double>>	getDefaultEdgesInSSSP(ExecutionEnvironment env)
static Edge<Long,Double>	getDefaultEdgeToBeRemoved()
static DataSet<Vertex<Long,Double>>	getDefaultVertexDataSet(ExecutionEnvironment env)

Methods inherited from class java.lang.Object

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

Field Detail

NUM_VERTICES

public static final int NUM_VERTICES

See Also:

Constant Field Values

VERTICES

public static final String VERTICES

See Also:

Constant Field Values

EDGES

public static final String EDGES

See Also:

Constant Field Values

EDGES_IN_SSSP

public static final String EDGES_IN_SSSP

See Also:

Constant Field Values

SRC_EDGE_TO_BE_REMOVED

public static final String SRC_EDGE_TO_BE_REMOVED

See Also:

Constant Field Values

TRG_EDGE_TO_BE_REMOVED

public static final String TRG_EDGE_TO_BE_REMOVED

See Also:

Constant Field Values

VAL_EDGE_TO_BE_REMOVED

public static final String VAL_EDGE_TO_BE_REMOVED

See Also:

Constant Field Values

RESULTED_VERTICES

public static final String RESULTED_VERTICES

See Also:

Constant Field Values

Method Detail

getDefaultVertexDataSet

public static DataSet<Vertex<Long,Double>> getDefaultVertexDataSet(ExecutionEnvironment env)

getDefaultEdgeDataSet

public static final DataSet<Edge<Long,Double>> getDefaultEdgeDataSet(ExecutionEnvironment env)

getDefaultEdgesInSSSP

public static final DataSet<Edge<Long,Double>> getDefaultEdgesInSSSP(ExecutionEnvironment env)

getDefaultEdgeToBeRemoved

public static final Edge<Long,Double> getDefaultEdgeToBeRemoved()