這是一個動作嗎？

NO，如果你在任何RDD做getNumPartition()，它只是獲取一個RDD的元（partitions.length），沒有任務將被提交。

這是一個轉型嗎？

我對轉型的理解是「當應用於RDD該函數應該返回一個RDD」。但是getNumPartition()返回整數。

入住RDD.scala

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

來源

2017-04-12 06:56:52 mrsrinivas

的功能定義：感謝您的信息。懷疑來自這裏https://www.analyticsvidhya.com/blog/2016/10/using-pyspark-to-perform-transformations-and-actions-on-rdd/。他們提到getNumPartition是一個Action。 – Satya

getNumPartitions是RDD操作還是轉換？

回答

這是一個動作嗎？

這是一個轉型嗎？

相關問題