diff options
| author | Nick Pentreath <nick.pentreath@gmail.com> | 2013-10-04 13:30:33 +0200 |
|---|---|---|
| committer | Nick Pentreath <nick.pentreath@gmail.com> | 2013-10-04 13:30:33 +0200 |
| commit | 0bd9b373d1d37a3df7a504098abcbd7421cf7477 (patch) | |
| tree | d1942ff7ddfe0f3b54a9e12775c49fd598022eaa /mllib | |
| parent | 1cbdcb9cb6cbfea2831db01e2a109c10f8bd30ae (diff) | |
| download | spark-0bd9b373d1d37a3df7a504098abcbd7421cf7477.tar.gz spark-0bd9b373d1d37a3df7a504098abcbd7421cf7477.tar.bz2 spark-0bd9b373d1d37a3df7a504098abcbd7421cf7477.zip | |
Reverting to using comma-delimited split
Diffstat (limited to 'mllib')
| -rw-r--r-- | mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala | 2 |
1 files changed, 1 insertions, 1 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 00b46aea47..5935d2754d 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 @@ -588,7 +588,7 @@ object ALS { val sc = new SparkContext(master, "ALS") val ratings = sc.textFile(ratingsFile).map { line => - val fields = line.split("\\D{2}|\\s|,") + val fields = line.split(',') Rating(fields(0).toInt, fields(1).toInt, fields(2).toDouble) } val model = new ALS(rank = rank, iterations = iters, lambda = lambda, |