notebook.community
Edit and run
In [1]: dataset = range(1,100) parallelized_data = sc.parallelize(dataset)
dataset = range(1,100) parallelized_data = sc.parallelize(dataset)
In [2]: parallelized_data.getNumPartitions()
parallelized_data.getNumPartitions()
Out[2]: 8
8
In [ ]: