pyspark.RDD.getNumPartitions

RDD. getNumPartitions ( ) → int [source]

返回RDD中的分区数量

新增于版本 1.1.0。

Returns
int

分区数量

示例 

>>> rdd = sc.parallelize([1, 2, 3, 4], 2)
>>> rdd.getNumPartitions()
2

上一篇

pyspark.RDD.getCheckpointFile

下一页

pyspark.RDD.getResourceProfile