scala实现wordcount
2016-09-06 13:12
417 查看
这里给出两种方式，供初学者参考。
方式一：
方式二：
方式一：
val lines = List("show me the money", "show me the meaning of being lonely", "triple kill", "mega kill","monster kill","holy shit")
val map = lines.flatMap { line => line.split(" ") }.foldLeft(Map.empty[String, Int]){(count, word) => count + (word -> (count.getOrElse(word, 0) + 1))}方式二：
lines.flatMap { line => line.split(" ") }.map { x => (x,1) }.groupBy(_._1).mapValues(f=>f.size).foreach(println)
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- Spark：用Scala和Java实现WordCount
- Scala 学习（六）--- 单机实现wordcount详细解读
- Akka初体验之scala版word-count 的实现
- Spark：用Scala和Java实现WordCount
- Spark：用Scala和Java实现WordCount
- WordCount的Scala实现
- Flink学习笔记 --- scala实现Flink的DataSet Source进行WordCount
- 用scala实现wordcount
- Spark：用Scala和Java实现WordCount
- 使用 scala 实现单机版 WordCount
- 快学Scala-Actor并发编程实现WordCount
- Spark：用Scala和Java实现WordCount
- Spark 程序 WordCount实现 Scala、Python
- maven构建Scala程序，实现spark的wordcount
- python、scala、java分别实现在spark上实现WordCount
- scala 实现WordCount
- Scala实现WordCount功能
- java和scala分别实现WordCount
- Spark：用Java和Scala实现WordCount
- Python+Hadoop Streaming实现MapReduce（word count）