pyspark.RDD.getNumPartitions¶

RDD.getNumPartitions() → int[source]¶

Returns the number of partitions in RDD

Examples

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