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

Class PageRankData

java.lang.Object

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

public class PageRankData
extends Object

Provides the default data sets used for the PageRank 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

Constructor Summary

Constructors

Constructor	Description
PageRankData()

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>	getDefaultPagesDataSet(org.apache.flink.api.java.ExecutionEnvironment env)
static int	getNumberOfPages()

Methods inherited from class java.lang.Object

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

Field Detail

EDGES

public static final Object[][] EDGES

Constructor Detail

PageRankData

public PageRankData()

Method Detail

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)

getDefaultPagesDataSet

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

getNumberOfPages

public static int getNumberOfPages()