spark rddが空になるまで.count（）

Question

StringのArrayBufferをRDDに変換するメソッドがあります。

def makeRddFromArray() : RDD[String] = { 
val rdd = Conf.sc.parallelize(listOfStrings) 
//rdd.count 
rdd} 

では、私はこのコメントを解除した場合、それはサイズ0のRDDを返すです）（rdd.countをコメントし、RDDは、適切なサイズです。誰かがなぜ私を説明することができますか？ ありがとう

Answer 1

rdd.countは、DAGをトリガーして要素の数を取得するアクションです。

RDDは

scala> rdd 
res0: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[0] at parallelize 
at <console>:24 

そのここに何を行っていないクラスを指定します。