0
RDDのgetNumPartitions
は変形かアクションですか?getNumPartitionsはRDDアクションまたは変換ですか?
RDDのgetNumPartitions
は変形かアクションですか?getNumPartitionsはRDDアクションまたは変換ですか?
getNumPartition()
を行う場合NOは、それだけでRDDのメタ(partitions.length
)を取り出し、何のタスクは提出されません。
変形についての私の理解は、"RDDにその機能が適用されたときにRDDを返すべきです"です。しかし、getNumPartition()
整数を返します。
RDD.scala
@Since("1.6.0")
final def getNumPartitions: Int = partitions.length
内の関数の定義を確認してください:情報をありがとう。疑念は、https://www.analyticsvidhya.com/blog/2016/10/using-pyspark-to-perform-transformations-and-actions-on-rdd/から来ました。彼らはActionとしてgetNumPartitionを挙げました。 – Satya