Changes based on review

techaddict · techaddict · commit 5149d4065954 · 2014-05-06T12:50:03.000+05:30
diff --git a/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala b/examples/src/main/scala/org/apache/spark/examples/mllib/MovieLensALS.scala
@@ -93,7 +93,7 @@ object MovieLensALS {
     val ratings = sc.textFile(params.input).map { line =>
       val fields = line.split("::")
       if (params.implicitPrefs) {
-        Rating(fields(0).toInt, fields(1).toInt, if (fields(2).toInt >= 3) 1.0 else 0.0)
+        Rating(fields(0).toInt, fields(1).toInt, if (fields(2).toDouble >= 2.5) 1.0 else 0.0)
       } else {
         Rating(fields(0).toInt, fields(1).toInt, fields(2).toDouble)
       }

Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,7 @@ object MovieLensALS {`
`93`	`93`	`val ratings = sc.textFile(params.input).map { line =>`
`94`	`94`	`val fields = line.split("::")`
`95`	`95`	`if (params.implicitPrefs) {`
`96`		`- Rating(fields(0).toInt, fields(1).toInt, if (fields(2).toInt >= 3) 1.0 else 0.0)`
	`96`	`+ Rating(fields(0).toInt, fields(1).toInt, if (fields(2).toDouble >= 2.5) 1.0 else 0.0)`
`97`	`97`	`} else {`
`98`	`98`	`Rating(fields(0).toInt, fields(1).toInt, fields(2).toDouble)`
`99`	`99`	`}`