In [1]:
dataset = range(1,100)

parallelized_data = sc.parallelize(dataset)

In [2]:
parallelized_data.getNumPartitions()


Out[2]:
8

In [ ]: