How to collect() each partition in scala ?

Tue, 30 Dec 2014 03:57:40 -0800 

Hi all,
i have one large data-set. when i am getting the number of partitions its
showing 43.
We can't collect() the large data-set in to  memory so i am thinking like
this, collect() each partitions so that it will be small in size.

Any thoughts ?

Reply via email to