spark-shuffle的读数据源码分析

对指定分区进行计算的抽象接口，觉得CoGroupedRDD（或者ShuffleRDD，可能compute细节不一样，可是shuffle读取的类或方法的调用时同样的）的compute方法为实现，源码：网络 override def compute(s: Partition, context: TaskContext): Iterator[(K, Array[Iterable[_]])] = {val

>>阅读原文<<