We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 128dced commit caa1c82Copy full SHA for caa1c82
src/main/scala/com/sparkTutorial/pairRdd/aggregation/reducebykey/WordCount.scala
@@ -14,7 +14,7 @@ object WordCount {
14
val wordRdd = lines.flatMap(line => line.split(" "))
15
val wordPairRdd = wordRdd.map(word => (word, 1))
16
17
- val wordCounts = wordPairRdd.reduceByKey(_ + _)
+ val wordCounts = wordPairRdd.reduceByKey((x, y) => x + y)
18
for ((word, count) <- wordCounts.collect()) println(word + " : " + count)
19
}
20
0 commit comments