2017-04-12 6 views

答えて

2

これはアクションですか?あなたはどのRDDにgetNumPartition()を行う場合

NOは、それだけでRDDのメタ(partitions.length)を取り出し、何のタスクは提出されません。

変換ですか?

変形についての私の理解は、"RDDにその機能が適用されたときにRDDを返すべきです"です。しかし、getNumPartition()整数を返します。


RDD.scala

@Since("1.6.0") 
    final def getNumPartitions: Int = partitions.length 
+0

内の関数の定義を確認してください:情報をありがとう。疑念は、https://www.analyticsvidhya.com/blog/2016/10/using-pyspark-to-perform-transformations-and-actions-on-rdd/から来ました。彼らはActionとしてgetNumPartitionを挙げました。 – Satya

関連する問題