Commitcaa1c82

authored

Update WordCount.scala

1 parent128dced commitcaa1c82Copy full SHA for caa1c82

File tree

-1

lines changed

src/main/scala/com/sparkTutorial/pairRdd/aggregation/reducebykey
- WordCount.scala

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ object WordCount {`
`14`	`14`	`valwordRdd= lines.flatMap(line=> line.split(""))`
`15`	`15`	`valwordPairRdd= wordRdd.map(word=> (word,1))`
`16`	`16`
`17`		`-valwordCounts= wordPairRdd.reduceByKey(_+ _)`
	`17`	`+valwordCounts= wordPairRdd.reduceByKey((x, y)=> x+ y)`
`18`	`18`	`for ((word, count)<- wordCounts.collect()) println(word+" :"+ count)`
`19`	`19`	`}`
`20`	`20`	`}`

Comments

(0)