pyspark.RDD.getNumPartitions

RDD.getNumPartitions() → int[source]

Returns the number of partitions in RDD

New in version 1.1.0.

Returns
int

number of partitions

Examples

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