diff options
Diffstat (limited to 'mllib')
| -rw-r--r-- | mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala | 4 |
1 files changed, 2 insertions, 2 deletions
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 index c668b0412c..8958040e36 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala @@ -211,8 +211,8 @@ class ALS private (var numBlocks: Int, var rank: Int, var iterations: Int, var l def computeYtY(factors: RDD[(Int, Array[Array[Double]])]) = { if (implicitPrefs) { Option( - factors.flatMapValues{ case factorArray => - factorArray.map{ vector => + factors.flatMapValues { case factorArray => + factorArray.view.map { vector => val x = new DoubleMatrix(vector) x.mmul(x.transpose()) } |