Spark Engine - Partition in RDD
rdd = sc.parallelize([1, 2, 3, 4], 2)
rdd.getNumPartitions
Return a new RDD by applying a function to each partition of this RDD.