use toSeq instead

witgo · Apr 8, 2014 · d3fe909 · d3fe909
1 parent 7a092a3
commit d3fe909
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/SVD.scala b/mllib/src/main/scala/org/apache/spark/mllib/linalg/SVD.scala
@@ -287,8 +287,7 @@ class SVD {
     val rows = data.map(entry =>
       (entry.i, (entry.j, entry.mval))).groupByKey()
     val emits = rows.flatMap {
-      case (rowind, colsI) =>
-        val cols = colsI.toList
+      case (rowind, cols) =>
         cols.flatMap {
           case (colind1, mval1) =>
             cols.map {

diff --git a/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala b/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala
@@ -426,7 +426,7 @@ class ALS private (
     : Array[Array[Double]] =
   {
     // Sort the incoming block factor messages by block ID and make them an array
-    val blockFactors = messages.toArray.sortBy(_._1).map(_._2) // Array[Array[Double]]
+    val blockFactors = messages.toSeq.sortBy(_._1).map(_._2).toArray // Array[Array[Double]]
     val numBlocks = blockFactors.length
     val numUsers = inLinkBlock.elementIds.length