Spark算子执行流程详解之五

22.combineByKey   def combineByKey[C](createCombiner: V => C,     mergeValue: (C, V) => C,     mergeCombiners: (C, C) => C,     partitioner: Partitioner,     mapSideCombine: Boolean = true,     serial

>>阅读原文<<