aboutsummaryrefslogtreecommitdiff
path: root/mllib/src/main
diff options
context:
space:
mode:
authorXiangrui Meng <meng@databricks.com>2015-08-14 10:25:11 -0700
committerJoseph K. Bradley <joseph@databricks.com>2015-08-14 10:25:11 -0700
commita0e1abbd010b9e73d472ce12ff1d987678005d32 (patch)
treec439c25caad95561001eacb76b08950051332ab4 /mllib/src/main
parentc8677d73666850b37ff937520e538650632ce304 (diff)
downloadspark-a0e1abbd010b9e73d472ce12ff1d987678005d32.tar.gz
spark-a0e1abbd010b9e73d472ce12ff1d987678005d32.tar.bz2
spark-a0e1abbd010b9e73d472ce12ff1d987678005d32.zip
[SPARK-9661] [MLLIB] minor clean-up of SPARK-9661
Some minor clean-ups after SPARK-9661. See my inline comments. MechCoder jkbradley Author: Xiangrui Meng <meng@databricks.com> Closes #8190 from mengxr/SPARK-9661-fix.
Diffstat (limited to 'mllib/src/main')
-rw-r--r--mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala5
-rw-r--r--mllib/src/main/scala/org/apache/spark/mllib/stat/Statistics.scala6
2 files changed, 4 insertions, 7 deletions
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala
index f31949f13a..82f05e4a18 100644
--- a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala
+++ b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala
@@ -674,10 +674,9 @@ class DistributedLDAModel private[clustering] (
}
/** Java-friendly version of [[topTopicsPerDocument]] */
- def javaTopTopicsPerDocument(
- k: Int): JavaRDD[(java.lang.Long, Array[Int], Array[java.lang.Double])] = {
+ def javaTopTopicsPerDocument(k: Int): JavaRDD[(java.lang.Long, Array[Int], Array[Double])] = {
val topics = topTopicsPerDocument(k)
- topics.asInstanceOf[RDD[(java.lang.Long, Array[Int], Array[java.lang.Double])]].toJavaRDD()
+ topics.asInstanceOf[RDD[(java.lang.Long, Array[Int], Array[Double])]].toJavaRDD()
}
// TODO:
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/stat/Statistics.scala b/mllib/src/main/scala/org/apache/spark/mllib/stat/Statistics.scala
index 24fe48cb8f..ef8d786070 100644
--- a/mllib/src/main/scala/org/apache/spark/mllib/stat/Statistics.scala
+++ b/mllib/src/main/scala/org/apache/spark/mllib/stat/Statistics.scala
@@ -221,9 +221,7 @@ object Statistics {
def kolmogorovSmirnovTest(
data: JavaDoubleRDD,
distName: String,
- params: java.lang.Double*): KolmogorovSmirnovTestResult = {
- val javaParams = params.asInstanceOf[Seq[Double]]
- KolmogorovSmirnovTest.testOneSample(data.rdd.asInstanceOf[RDD[Double]],
- distName, javaParams: _*)
+ params: Double*): KolmogorovSmirnovTestResult = {
+ kolmogorovSmirnovTest(data.rdd.asInstanceOf[RDD[Double]], distName, params: _*)
}
}