}.cache()
val cluster = KMeans.train(data, 3, 20)
val vectorsAndClusterIdx = data.map{ point =>
val prediction = cluster.predict(point)
(point.toString, prediction)
}
vectorsAndClusterIdx.collect
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/MLlib-Show-an-e
44a)))
Typing /groups/ em command line I see:
res1: org.apache.spark.rdd.RDD[(Int, Iterable[Array[Double]])] =
ShuffledRDD[28] at groupBy at :24
How can I see the results?
Thanks.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/MLlib-Show-an-element-in-RDD-Int-Iterable-Array-
