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

>>阅读原文<<