查看spark RDD 各分區內容

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

>>阅读原文<<