查看spark RDD 各分区内容

mapPartitionsWithIndex def mapPartitionsWithIndex[U](f: (Int, Iterator[T]) => Iterator[U], preservesPartitioning: Boolean = false)(implicit arg0: ClassTag[U]): RDD[U]java 函数做用同mapPartitions，不过提供了分区的索引

>>阅读原文<<