Spark 使用sortByKey进行二次排序

Spark的sortByKey API容许自定义排序规则,这样就能够进行自定义的二次排序、三次排序等等。 先来看一下sortByKey的源码实现:java def sortByKey(): JavaPairRDD[K, V] = sortByKey(true) def sortByKey(ascending: Boolean): JavaPairRDD[K, V] = { val com
相关文章
相关标签/搜索