Thanks. Repartitioning works now.
Thread closed :)
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Cannot-get-repartitioning-to-work-tp25852p25858.html
Sent from the Apache Spark User List mailing list archive at Nabble.com
repartitioning to work? See code below:
>
> val
> results=input.reduceByKey((x,y)=>x+y,10).persist(StorageLevel.DISK_ONLY)
> results.repartition(20)
> println(results.partitions.size)
>
>
>
> --
> View this message in context:
> http://apache-spark-user
01560.n3.nabble.com/Cannot-get-repartitioning-to-work-tp25852.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail
