aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei.zaharia@gmail.com>2013-07-14 08:03:13 +0000
committerMatei Zaharia <matei.zaharia@gmail.com>2013-07-14 08:03:13 +0000
commit931e4c96ef56302cc384086d1faa0f4ca3258e8b (patch)
treec015e7e676d9b78d1a05495eacebf1118a6f75cf
parentc5c38d1987137a1dc5eb66dd1065735a542ef9b5 (diff)
downloadspark-931e4c96ef56302cc384086d1faa0f4ca3258e8b.tar.gz
spark-931e4c96ef56302cc384086d1faa0f4ca3258e8b.tar.bz2
spark-931e4c96ef56302cc384086d1faa0f4ca3258e8b.zip
Fix a comment
-rw-r--r--mllib/src/main/scala/spark/mllib/recommendation/ALS.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala b/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala
index dec3701ec0..21eb21276e 100644
--- a/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala
+++ b/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala
@@ -161,7 +161,7 @@ class ALS private (var numBlocks: Int, var rank: Int, var iterations: Int, var l
for (productBlock <- 0 until numBlocks) {
// Create an array of (product, Seq(Rating)) ratings
val groupedRatings = blockRatings(productBlock).groupBy(_.product).toArray
- // Sort them by user ID
+ // Sort them by product ID
val ordering = new Ordering[(Int, ArrayBuffer[Rating])] {
def compare(a: (Int, ArrayBuffer[Rating]), b: (Int, ArrayBuffer[Rating])): Int = a._1 - b._1
}