rdd.mapPartitions(x => new Iterator(x.head)) On Fri, Sep 18, 2015 at 3:57 PM, Ulanov, Alexander <alexander.ula...@hpe.com > wrote:
> Dear Spark developers, > > > > Is it possible (and how to do it if possible) to pick one element per > physical node from an RDD? Let’s say the first element of any partition on > that node. The result would be an RDD[element], the count of elements is > equal to the N of nodes that has partitions of the initial RDD. > > > > Best regards, Alexander >
