Skip to content

Commit ad6b9ce

Browse files
committed
Revert "make ClassificatinModel.predict(JavaRDD) return JavaDoubleRDD"
This reverts commit a89763b.
1 parent 0054684 commit ad6b9ce

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

mllib/src/main/scala/org/apache/spark/mllib/classification/ClassificationModel.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
package org.apache.spark.mllib.classification
1919

2020
import org.apache.spark.annotation.Experimental
21-
import org.apache.spark.api.java.{JavaDoubleRDD, JavaRDD}
21+
import org.apache.spark.api.java.JavaRDD
2222
import org.apache.spark.mllib.linalg.Vector
2323
import org.apache.spark.rdd.RDD
2424

@@ -48,8 +48,8 @@ trait ClassificationModel extends Serializable {
4848
/**
4949
* Predict values for examples stored in a JavaRDD.
5050
* @param testData JavaRDD representing data points to be predicted
51-
* @return a JavaDoubleRDD where each entry contains the corresponding prediction
51+
* @return a JavaRDD[java.lang.Double] where each entry contains the corresponding prediction
5252
*/
53-
def predict(testData: JavaRDD[Vector]): JavaDoubleRDD =
54-
JavaDoubleRDD.fromRDD(predict(testData.rdd))
53+
def predict(testData: JavaRDD[Vector]): JavaRDD[java.lang.Double] =
54+
predict(testData.rdd).toJavaRDD().asInstanceOf[JavaRDD[java.lang.Double]]
5555
}

0 commit comments

Comments
 (0)