Uses of Class
org.apache.wayang.basic.data.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 java.lang.String
OutputSerializer. apply(Tuple2<java.lang.String,java.lang.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(java.lang.String inputFileUrl, java.util.Collection<Tuple2<java.lang.String,java.lang.Integer>> collector)
Creates theWayangPlan
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<java.lang.Long,java.lang.Float>
PageRankMapping.RankInitializer. apply(java.lang.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 theJavaPlatform
that creates a TSV file.Constructor parameters in org.apache.wayang.java.operators with type arguments of type Tuple2 Constructor Description JavaTsvFileSource(DataSetType<Tuple2> type)
-
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<java.lang.Integer,Tuple2<java.lang.Integer,double[]>>
KMeansCompute. aggregate(Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input1, Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input2)
Tuple2
KMeansCompute. process(double[] input, ML4allModel model)
Tuple2<java.lang.Integer,double[]>
KMeansUpdate. process(Tuple2<java.lang.Integer,Tuple2<java.lang.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<java.lang.Integer,Tuple2<java.lang.Integer,double[]>>
KMeansCompute. aggregate(Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input1, Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input2)
Methods in org.apache.wayang.ml4all.algorithms.kmeans with parameters of type Tuple2 Modifier and Type Method Description Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>>
KMeansCompute. aggregate(Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input1, Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input2)
Tuple2<java.lang.Integer,double[]>
KMeansUpdate. process(Tuple2<java.lang.Integer,Tuple2<java.lang.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<java.lang.Integer,Tuple2<java.lang.Integer,double[]>>
KMeansCompute. aggregate(Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input1, Tuple2<java.lang.Integer,Tuple2<java.lang.Integer,double[]>> input2)
ML4allModel
KMeansUpdate. assign(java.util.List<Tuple2<java.lang.Integer,double[]>> input, ML4allModel model)
java.lang.Double
KMeansConvergeOrMaxIterationsLoop. prepareConvergenceDataset(java.util.ArrayList<Tuple2<java.lang.Integer,double[]>> newCenters, ML4allModel model)
Tuple2<java.lang.Integer,double[]>
KMeansUpdate. process(Tuple2<java.lang.Integer,Tuple2<java.lang.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 theSparkPlatform
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[],java.lang.Integer>>
SparkDecisionTreeClassificationOperator.Model. transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],java.lang.Integer>>
SparkKMeansOperator.Model. transform(org.apache.spark.api.java.JavaRDD<double[]> input)
org.apache.spark.api.java.JavaRDD<Tuple2<double[],java.lang.Double>>
SparkLinearRegressionOperator.Model. transform(org.apache.spark.api.java.JavaRDD<double[]> input)
-