WordCount的Scala实现
2017-12-05 18:36
281 查看
话不多看代码
结果如下图(可以看到每一步的执行结果)
println("***********test********************") val lines=List("hello tom hello jerry","hello ketty hello cat"); println(lines) val words=lines.map(_.split(" ")).flatten println(words) val wordsAndOne = words.map(x=>(x,1)) val wordsOne = words.map((_,1)) println(wordsAndOne) println(wordsOne) val wordGroup=wordsAndOne.groupBy(_._1) println(wordGroup) var result=wordGroup.map(t=>(t._1,t._2.size)) var result1 = wordGroup.mapValues(_.size) println(result) println(result1) var wordCount = result.toList.sortBy(_._2).reverse println(wordCount)
结果如下图(可以看到每一步的执行结果)
相关文章推荐
- 快学Scala-Actor并发编程实现WordCount
- Spark:用Scala和Java实现WordCount
- Flink学习笔记 --- scala实现Flink的DataSet Source进行WordCount
- python、scala、java分别实现在spark上实现WordCount
- 用scala实现wordcount
- maven构建Scala程序,实现spark的wordcount
- Spark:用Scala和Java实现WordCount
- Spark:用Scala和Java实现WordCount
- Akka初体验之scala版word-count 的实现
- Scala实现WordCount功能
- scala 实现WordCount
- Spark 程序 WordCount实现 Scala、Python
- Scala 学习(六)--- 单机实现wordcount详细解读
- Spark:用Scala和Java实现WordCount
- Spark:用Java和Scala实现WordCount
- java和scala分别实现WordCount
- 使用 scala 实现单机版 WordCount
- scala实现wordcount
- Spark:用Scala和Java实现WordCount
- scala-wordcount