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

>>阅读原文<<