diff options
| author | Holden Karau <holden@pigscanfly.ca> | 2013-08-15 23:08:48 -0700 |
|---|---|---|
| committer | Holden Karau <holden@pigscanfly.ca> | 2013-08-15 23:08:48 -0700 |
| commit | 8fc40818d714651c0fb360a26b64a3ab12559961 (patch) | |
| tree | f6de8377dc7b4943347be1b57659bfb7dcd755dd /mllib | |
| parent | d145da818ee14c01ff08b29a546fb3c87016aa51 (diff) | |
| download | spark-8fc40818d714651c0fb360a26b64a3ab12559961.tar.gz spark-8fc40818d714651c0fb360a26b64a3ab12559961.tar.bz2 spark-8fc40818d714651c0fb360a26b64a3ab12559961.zip | |
Fix
Diffstat (limited to 'mllib')
| -rw-r--r-- | mllib/src/main/scala/spark/mllib/recommendation/ALS.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala b/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala index aeacbca510..9097f46db9 100644 --- a/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala +++ b/mllib/src/main/scala/spark/mllib/recommendation/ALS.scala @@ -133,9 +133,9 @@ class ALS private (var numBlocks: Int, var rank: Int, var iterations: Int, var l var products = productOutLinks.mapPartitions {itr => val rand = new Random() itr.map({case (x, y) => - (x, y.elementIds.map(u => randomFactor(rank, rand))) + (x, y.elementIds.map(u => randomFactor(rank, rand))) }) - }) + } for (iter <- 0 until iterations) { // perform ALS update |