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.StringOutputSerializer. 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 WayangPlanWordCountWithJavaNativeAPI. createWayangPlan(java.lang.String inputFileUrl, java.util.Collection<Tuple2<java.lang.String,java.lang.Integer>> collector)Creates theWayangPlanfor 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 classFlinkTsvFileSink<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 classJavaTsvFileSink<T extends Tuple2<?,?>>Operatorfor theJavaPlatformthat 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)Tuple2KMeansCompute. 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)ML4allModelKMeansUpdate. assign(java.util.List<Tuple2<java.lang.Integer,double[]>> input, ML4allModel model)java.lang.DoubleKMeansConvergeOrMaxIterationsLoop. 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 classSparkTsvFileSink<T extends Tuple2<?,?>>Operatorfor theSparkPlatformthat 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)
-