如何使用Scala实现worldcount功能
这篇文章主要讲解了“如何使用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功能这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341