spark源碼分析：（二）1.RDD個數的判斷

RDD創建個數的判斷。 代碼如下： val rdd1 = sc.textFile(input,3) val rdd2 = rdd1.map( x => x + s"(${x.length})" ) println(rdd2.collect().mkString("\n")) 通過debug，我們來看看rdd1，rdd2是什麼類型的RDD。由於RDD之間並沒有發生Shuffle，因此RDD之間的依賴

>>阅读原文<<