List(x.next).iterator is giving you the first element from each partition, which would be 1, 4 and 7 respectively.
On 3/18/15, 10:19 AM, "ashish.usoni" <ashish.us...@gmail.com> wrote: >I am trying to understand about mapPartitions but i am still not sure how >it >works > >in the below example it create three partition >val parallel = sc.parallelize(1 to 10, 3) > >and when we do below >parallel.mapPartitions( x => List(x.next).iterator).collect > >it prints value >Array[Int] = Array(1, 4, 7) > >Can some one please explain why it prints 1,4,7 only > >Thanks, > > > > >-- >View this message in context: >http://apache-spark-user-list.1001560.n3.nabble.com/mapPartitions-How-Does >-it-Works-tp22123.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: user-h...@spark.apache.org > --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
