org.apache.flink.graph.examples.utils

Class ExampleUtils

java.lang.Object

org.apache.flink.graph.examples.utils.ExampleUtils

public class ExampleUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExampleUtils.PrintingOutputFormatWithMessage<T>

Method Summary

Modifier and Type	Method and Description
static DataSet<Edge<Long,Double>>	getLongDoubleEdgeData(ExecutionEnvironment env)
static DataSet<Vertex<Long,Double>>	getLongDoubleVertexData(ExecutionEnvironment env)
static DataSet<Edge<Long,NullValue>>	getRandomEdges(ExecutionEnvironment env, long numVertices)
static DataSet<Vertex<Long,NullValue>>	getVertexIds(ExecutionEnvironment env, long numVertices)
static void	printResult(DataSet set, String msg)

Methods inherited from class java.lang.Object

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

Method Detail

printResult

public static void printResult(DataSet set,
                               String msg)

getVertexIds

public static DataSet<Vertex<Long,NullValue>> getVertexIds(ExecutionEnvironment env,
                                                           long numVertices)

getRandomEdges

public static DataSet<Edge<Long,NullValue>> getRandomEdges(ExecutionEnvironment env,
                                                           long numVertices)

getLongDoubleVertexData

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

getLongDoubleEdgeData

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