SparkでreduceByKeyしたあとにsortByKeyで降順にソートしたかったのでメモ

sortByKey()の引数にfalseを渡す。

val totalByItem = rdd.reduceByKey((x, y) =>  (x + y)) //要素毎にカウントして (要素, 個数)のtupleにする
val flipped = totalByItem.map(x => (x._2, x._1)) // tupleの要素と個数を入れ替えて(個数､ 要素)にする
val sorted = flipped.sortByKey(false) // 降順でソート