Change basic sum scala example to match java one more closely

databricks · Mar 7, 2014 · 11f8779 · 11f8779
1 parent 658a08c
commit 11f8779
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/scala/com/oreilly/learningsparkexamples/scala/BasicSum.scala b/src/main/scala/com/oreilly/learningsparkexamples/scala/BasicSum.scala
@@ -13,8 +13,7 @@ object BasicSum {
       }
       val sc = new SparkContext(master, "BasicMap", System.getenv("SPARK_HOME"))
       val input = sc.parallelize(List(1,2,3,4))
-      val squared = input.map(x => x*x)
-      val result = squared.fold(0)((x, y) => (x + y))
+      val result = input.fold(0)((x, y) => (x + y))
       println(result)
     }
 }