Update StatefulNetworkWordCount.scala

marmbrus · Aug 28, 2014 · 57e704c · 57e704c
1 parent a7d145e
commit 57e704c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala
@@ -44,7 +44,7 @@ object StatefulNetworkWordCount {
     StreamingExamples.setStreamingLogLevels()
 
     val updateFunc = (values: Seq[Int], state: Option[Int]) => {
-      val currentCount = values.foldLeft(0)(_ + _)
+      val currentCount = values.sum
 
       val previousCount = state.getOrElse(0)