查看spark RDD 各分區內容

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