Github user tex0l commented on a diff in the pull request:
https://github.com/apache/spark/pull/8849#discussion_r40029265
--- Diff:
mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeansModel.scala ---
@@ -77,6 +77,22 @@ class KMeansModel @Since("1.1.0") (@Since("1.0.0") val
clusterCenters: Array[Vec
def predict(points: JavaRDD[Vector]): JavaRDD[java.lang.Integer] =
predict(points.rdd).toJavaRDD().asInstanceOf[JavaRDD[java.lang.Integer]]
+ /** */
+ def distanceToCenters(point: Vector): (Int, Double) = {
--- End diff --
Indeed it was... Sorry about that.
2015-09-21 14:01 GMT-07:00 Bertrand Dechoux <[email protected]>:
> In
> mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeansModel.scala
> <https://github.com/apache/spark/pull/8849#discussion_r40025294>:
>
> > @@ -77,6 +77,22 @@ class KMeansModel @Since("1.1.0") (@Since("1.0.0")
val clusterCenters: Array[Vec
> > def predict(points: JavaRDD[Vector]): JavaRDD[java.lang.Integer] =
> >
predict(points.rdd).toJavaRDD().asInstanceOf[JavaRDD[java.lang.Integer]]
> >
> > + /** */
> > + def distanceToCenters(point: Vector): (Int, Double) = {
>
> Indeed not. The diff I received must have been a work in progress. This is
> now fixed.
>
> â
> Reply to this email directly or view it on GitHub
> <https://github.com/apache/spark/pull/8849/files#r40025294>.
>
--
Timothée Rebours
13, rue Georges Bizet
78380 BOUGIVAL
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
