Reverting to using comma-delimited split
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/0bd9b373 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/0bd9b373 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/0bd9b373 Branch: refs/heads/master Commit: 0bd9b373d1d37a3df7a504098abcbd7421cf7477 Parents: 1cbdcb9 Author: Nick Pentreath <nick.pentre...@gmail.com> Authored: Fri Oct 4 13:30:33 2013 +0200 Committer: Nick Pentreath <nick.pentre...@gmail.com> Committed: Fri Oct 4 13:30:33 2013 +0200 ---------------------------------------------------------------------- .../src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/0bd9b373/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala ---------------------------------------------------------------------- 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 00b46ae..5935d27 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,
