spark小应用一：wordcount，按词频降序（SCALA）

val rdd = sc.textFile("hdfs://mycluster/user/bpf/sparkApp/wordcount/input") val wordcount = rdd.flatMap(_.split(" ")).map((_,1)).reduceByKey(_+_) 这样获得的结果并无按照某种规则排序php 按照value值进行降序。（出现次数多的在前） 思路：key va

>>阅读原文<<