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

Class WebLogData

java.lang.Object

org.apache.flink.examples.java.relational.util.WebLogData

public class WebLogData
extends Object

Provides the default data sets used for the Weblog Analysis 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[][]	DOCUMENTS
static Object[][]	RANKS
static Object[][]	VISITS

Constructor Summary

Constructors

Constructor	Description
WebLogData()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple2<String,String>>	getDocumentDataSet(org.apache.flink.api.java.ExecutionEnvironment env)
static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>>	getRankDataSet(org.apache.flink.api.java.ExecutionEnvironment env)
static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple2<String,String>>	getVisitDataSet(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

DOCUMENTS

public static final Object[][] DOCUMENTS

RANKS

public static final Object[][] RANKS

VISITS

public static final Object[][] VISITS

Constructor Detail

WebLogData

public WebLogData()

Method Detail

getDocumentDataSet

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

getRankDataSet

public static org.apache.flink.api.java.DataSet<org.apache.flink.api.java.tuple.Tuple3<Integer,String,Integer>> getRankDataSet(org.apache.flink.api.java.ExecutionEnvironment env)

getVisitDataSet

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