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

>>阅读原文<<