Scala实现WordCount

世上没有什么困难的事，只有不去努力的人，即使一个小小的问题，如果你都不去操作的话，你永远不能体会那个过程，，一遍不行，我们来2遍，，，，反反复复，千锤百炼，，，
—————————————送给正在努力的你

Scala实现WordCount

object ScalaWordCountAPP {def main(args: Array[String]): Unit = {val lins = List("hello java python", "hello java", "hello scala java scala hello")//切开压平val words = lins.flatMap(_.split(" "))//把每个单词生成一个一个的tupleval tuples = words.map((_, 1))//一key进行分组val grouped = tuples.groupBy(_._1)//统计value的长度val sumed = grouped.mapValues(_.size)//排序val sorted = sumed.toList.sortBy(_._2)//降序排列val result =sorted.reverseprintln( result)}}

结果显示

List((hello,4), (java,3), (scala,2), (python,1))
Process finished with exit code 0

在xshell上操作流程

scala> val lins = List("hello java python", "hello java", "hello scala java scala hello")
lins: List[String] = List(hello java python, hello java, hello scala java scala hello)scala>  val words = lins.flatMap(_.split(" "))
words: List[String] = List(hello, java, python, hello, java, hello, scala, java, scala, hello)scala>  val tuples = words.map((_, 1))
tuples: List[(String, Int)] = List((hello,1), (java,1), (python,1), (hello,1), (java,1), (hello,1), (scala,1), (java,1), (scala,1), (hello,1))scala> val grouped = tuples.groupBy(_._1)
grouped: scala.collection.immutable.Map[String,List[(String, Int)]] = Map(scala -> List((scala,1), (scala,1)), java -> List((java,1), (java,1), (java,1)), hello -> List((hello,1), (hello,1), (hello,1), (hello,1)), python -> List((python,1)))scala> val sumed = grouped.mapValues(_.size)
sumed: scala.collection.immutable.Map[String,Int] = Map(scala -> 2, java -> 3, hello -> 4, python -> 1)scala> val sorted = sumed.toList.sortBy(_._2)
sorted: List[(String, Int)] = List((python,1), (scala,2), (java,3), (hello,4))scala> val result =sorted.reverse
result: List[(String, Int)] = List((hello,4), (java,3), (scala,2), (python,1))
整体来一遍：
scala>
scala> lins.flatMap(_.split(" ")).map((_, 1)).groupBy(_._1).mapValues(_.size).toList.sortBy(_._2)
res8: List[(String, Int)] = List((python,1), (scala,2), (java,3), (hello,4))

万事皆有方法，现在的你没有找到，没有关系，只要你不断坚持，终会发现，，，
—————————————送给正在寻找问题的你

Scala实现WordCount相关推荐

scala打印服务器消息,Spark中使用Scala实现WordCount业务
Spark中使用Scala实现WordCount业务创建一个Project sbt选择1.0.4 Scala选择2.11.8 配置路径 Project Sources Dependencies 新建 ...
Scala实现WordCount简易案例
Scala实现WordCount简易案例下面的代码是在IDEA中进行单词计数的小案例 object WordCount {def main(args: Array[String]): Unit = ...
Scala 的wordCount
文章目录 Scala 的wordCount 使用java的方式统计单词的数量使用scala的方式统计单词的数量链式调用(spark) Scala 的wordCount 使用java的方式统计单词的 ...
Scala：WordCount有关函数浅析
目录 map/flatMap/flatten groupBy reduce/reduceLeft/reduceRight sortBy mapValues foldLeft/foldRight/fol ...
用scala写wordcount
笨人勤总结,忘了再捡起来. 1.scala一些预热操作 1.1 to 是一个方法,()可以进行参数传递,map()把每一个元素取出来进行相应的操作, print(1.to(10).map(_*10) ...
09_Flink入门案例、word-count程序（java和scala版本）、添加依赖、Flink Streaming和Batch的区别、在集群上执行程序等
1.9.Flink入门案例-wordCount 1.9.1.开发工具 1.9.2.编写java版本word-count程序 1.9.2.1.添加Flink Maven依赖 1.9.2.2.编写word ...
Spark利用（idea+maven+scala）创建wordcount打包jar并在spark on yarn上运行——Spark的开发
今天的你不付昨天的辛苦,今天的辛苦定会拥抱明日的幸福, 每一次的成长,都要给自己以鼓励,每一次的突破,都给自己以信心,万花丛中我不是最美,但我有我的自信 ------------送给一直努力的你今天 ...
wordcount代码_Scala小案例之wordcount
写一个简单的word文档: scala实现wordcount代码如下: import org.apache.spark.rdd.RDD import org.apache.spark.SparkCon ...
flink wordcount示例
pom 完整pom <?xml version="1.0" encoding="UTF-8"?> <project xmlns="h ...

Scala实现WordCount

Scala实现WordCount

结果显示

在xshell上操作流程

Scala实现WordCount相关推荐

最新文章

热门文章