spark RDD算子（六）之键值对聚合操做reduceByKey，foldByKey，排序操做sortByKey

reduceByKey def reduceByKey(func: (V, V) => V): RDD[(K, V)] def reduceByKey(func: (V, V) => V, numPartitions: Int): RDD[(K, V)] def reduceByKey(partitioner: Partitioner, func: (V, V) => V): RDD[(K,

>>阅读原文<<