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之间的依赖

>>阅读原文<<