Uses of Class
org.apache.wayang.basic.data.Tuple2

Packages that use Tuple2

Package	Description
org.apache.wayang.api.sql.calcite.converter.functions
org.apache.wayang.applications
org.apache.wayang.apps.wordcount
org.apache.wayang.basic.data
org.apache.wayang.basic.mapping
org.apache.wayang.flink.operators
org.apache.wayang.java.operators
org.apache.wayang.jdbc.execution
org.apache.wayang.ml4all.algorithms.kmeans
org.apache.wayang.spark.model
org.apache.wayang.spark.operators
org.apache.wayang.spark.operators.ml

Uses of Tuple2 in org.apache.wayang.api.sql.calcite.converter.functions

Methods in org.apache.wayang.api.sql.calcite.converter.functions with parameters of type Tuple2

Modifier and Type	Method	Description
Record	JoinFlattenResult.apply(Tuple2<Record,Record> tuple2)
Record	MultiConditionJoinFuncImpl.apply(Tuple2<Record,Record> tuple2)

Uses of Tuple2 in org.apache.wayang.applications

Methods in org.apache.wayang.applications with parameters of type Tuple2

Modifier and Type	Method	Description
String	OutputSerializer.apply(Tuple2<String,Integer> tuple)

Uses of Tuple2 in org.apache.wayang.apps.wordcount

Method parameters in org.apache.wayang.apps.wordcount with type arguments of type Tuple2

Modifier and Type	Method	Description
static WayangPlan	WordCountWithJavaNativeAPI.createWayangPlan(String inputFileUrl, Collection<Tuple2<String,Integer>> collector)	Creates the WayangPlan for the word count app.

Uses of Tuple2 in org.apache.wayang.basic.data

Methods in org.apache.wayang.basic.data that return Tuple2

Modifier and Type	Method	Description
Tuple2<T1,T0>	Tuple2.swap()

Uses of Tuple2 in org.apache.wayang.basic.mapping

Methods in org.apache.wayang.basic.mapping that return Tuple2

Modifier and Type	Method	Description
Tuple2<Long,Float>	PageRankMapping.RankInitializer.apply(Long vertexId)

Uses of Tuple2 in org.apache.wayang.flink.operators

Classes in org.apache.wayang.flink.operators with type parameters of type Tuple2

Modifier and Type	Class	Description
class	FlinkTsvFileSink<Type extends Tuple2<?,?>>	Created by bertty on 31-10-17.

Uses of Tuple2 in org.apache.wayang.java.operators

Classes in org.apache.wayang.java.operators with type parameters of type Tuple2

Modifier and Type	Class	Description
class	JavaTsvFileSink<T extends Tuple2<?,?>>	Operator for the JavaPlatform that creates a TSV file.

Constructor parameters in org.apache.wayang.java.operators with type arguments of type Tuple2

Modifier	Constructor	Description
	JavaTsvFileSource(DataSetType<Tuple2> type)

Uses of Tuple2 in org.apache.wayang.jdbc.execution

Methods in org.apache.wayang.jdbc.execution that return Tuple2

Modifier and Type	Method	Description
protected Tuple2<String,SqlQueryChannel.Instance>	JdbcExecutor.createSqlQuery(ExecutionStage stage, OptimizationContext context)	Creates a query channel and the sql statement

Uses of Tuple2 in org.apache.wayang.ml4all.algorithms.kmeans

Methods in org.apache.wayang.ml4all.algorithms.kmeans that return Tuple2

Modifier and Type	Method	Description
Tuple2<Integer,Tuple2<Integer,double[]>>	KMeansCompute.aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1, Tuple2<Integer,Tuple2<Integer,double[]>> input2)
Tuple2	KMeansCompute.process(double[] input, ML4allModel model)
Tuple2<Integer,double[]>	KMeansUpdate.process(Tuple2<Integer,Tuple2<Integer,double[]>> input, ML4allModel model)

Methods in org.apache.wayang.ml4all.algorithms.kmeans that return types with arguments of type Tuple2

Modifier and Type	Method	Description
Tuple2<Integer,Tuple2<Integer,double[]>>	KMeansCompute.aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1, Tuple2<Integer,Tuple2<Integer,double[]>> input2)

Methods in org.apache.wayang.ml4all.algorithms.kmeans with parameters of type Tuple2

Modifier and Type	Method	Description
Tuple2<Integer,Tuple2<Integer,double[]>>	KMeansCompute.aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1, Tuple2<Integer,Tuple2<Integer,double[]>> input2)
Tuple2<Integer,double[]>	KMeansUpdate.process(Tuple2<Integer,Tuple2<Integer,double[]>> input, ML4allModel model)

Method parameters in org.apache.wayang.ml4all.algorithms.kmeans with type arguments of type Tuple2

Modifier and Type	Method	Description
Tuple2<Integer,Tuple2<Integer,double[]>>	KMeansCompute.aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1, Tuple2<Integer,Tuple2<Integer,double[]>> input2)
ML4allModel	KMeansUpdate.assign(List<Tuple2<Integer,double[]>> input, ML4allModel model)
Double	KMeansConvergeOrMaxIterationsLoop.prepareConvergenceDataset(ArrayList<Tuple2<Integer,double[]>> newCenters, ML4allModel model)
Tuple2<Integer,double[]>	KMeansUpdate.process(Tuple2<Integer,Tuple2<Integer,double[]>> input, ML4allModel model)

Uses of Tuple2 in org.apache.wayang.spark.model

Methods in org.apache.wayang.spark.model that return types with arguments of type Tuple2

Modifier and Type	Method	Description
default org.apache.spark.api.java.JavaRDD<Tuple2<X,Y>>	SparkMLModel.transform(org.apache.spark.api.java.JavaRDD<X> input)	Deprecated.

Uses of Tuple2 in org.apache.wayang.spark.operators

Classes in org.apache.wayang.spark.operators with type parameters of type Tuple2

Modifier and Type	Class	Description
class	SparkTsvFileSink<T extends Tuple2<?,?>>	Operator for the SparkPlatform that creates a TSV file.

Uses of Tuple2 in org.apache.wayang.spark.operators.ml

Methods in org.apache.wayang.spark.operators.ml that return types with arguments of type Tuple2

Modifier and Type	Method	Description
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Integer>>	SparkDecisionTreeClassificationOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Double>>	SparkDecisionTreeRegressionOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Integer>>	SparkKMeansOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Double>>	SparkLinearRegressionOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Double>>	SparkLinearSVCOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],Double>>	SparkLogisticRegressionOperator.Model.transform(org.apache.spark.api.java.JavaRDD<double[]> input)