spark内核揭秘-09-RDD的count操作 触发Job全生命周期-01

RDD源码的count方法： 从上面代码可以看出来，count方法触发SparkContext的runJob方法的调用： 进入 runJob(rdd, func, 0 until rdd.partitions.size, false)方法： 进一步跟踪runJob(rdd, (context: TaskContext, iter: Iterator[T]) => func(iter), parti

>>阅读原文<<