Spark 使用sortByKey進行二次排序

Spark的sortByKey API容許自定義排序規則,這樣就能夠進行自定義的二次排序、三次排序等等。 先來看一下sortByKey的源碼實現:java def sortByKey(): JavaPairRDD[K, V] = sortByKey(true) def sortByKey(ascending: Boolean): JavaPairRDD[K, V] = { val com
相關文章
相關標籤/搜索