这篇文章主要讲解了“如何使用Scala实现worldcount功能”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“如何使用Scala实现worldcount功能”吧!
新建ScalaWorldCount对象:
package com.ruozedata.day4
object ScalaWorldCount {
def main(args: Array[String]): Unit = {
val lines = List("hello ruoze hello jepson","hello ruoze hello jepson hello china")
val wc = lines.flatMap(_.split(" ")).map((_,1)).groupBy(_._1).map(t=>(t._1,t._2.size)).toList // .sortBy(_._2).reverse
for(j <- 0 until wc.length) println(wc(j)+"\t")
val wc = lines.flatMap(_.split(" ")).map((_,1)).groupBy(_._1).mapValues(_.foldLeft(0)(_+_._2))
for(i <- wc) println(i+"\t")
}
}
运行结果:
(china,1)
(ruoze,2)
(jepson,2)
(hello,5)
Process finished with exit code 0
感谢各位的阅读,以上就是“如何使用Scala实现worldcount功能”的内容了,经过本文的学习后,相信大家对如何使用Scala实现worldcount功能这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!