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

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

>>阅读原文<<