Fix local wc style

apache · Nov 20, 2014 · 44415b9 · 44415b9
1 parent 94a4691
commit 44415b9
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/examples/src/main/scala/org/apache/spark/examples/DFSReadWriteTest.scala b/examples/src/main/scala/org/apache/spark/examples/DFSReadWriteTest.scala
@@ -94,12 +94,13 @@ object DFSReadWriteTest {
   }
 
   def runLocalWordCount(fileContents: List[String]): Int = {
-    fileContents.flatMap {
-      ln => ln.split(" ") }.flatMap {
-      ln => ln.split("\t") }.filter {
-      ln => ln.size > 0 }.groupBy {
-      w => w }.mapValues {
-      lst => lst.size }.values.sum
+    fileContents.flatMap(_.split(" "))
+      .flatMap(_.split("\t"))
+      .filter(_.size > 0)
+      .groupBy(w => w)
+      .mapValues(_.size)
+      .values
+      .sum
   }
 
   def main(args: Array[String]) {