《Spark商业案例与性能调优实战100课》第34课：彻底解密Spark 2.1.X中Shuffle 中SortShuffleWriter排序源码内幕解密

 def partitionedIterator: Iterator[(Int, Iterator[Product2[K, C]])] = {     val usingMap = aggregator.isDefined     val collection: WritablePartitionedPairCollection[K, C] = if (usingMap) map else buffer     if (spills.isEmpty) {       // Special case: if we have only in-memory data, we don't need to merge streams, and perhaps       //