Spark:coalesce()方法和repartition()方法

1、coalesce()方法 def coalesce(numPartitions: Int, shuffle: Boolean = false)(implicit ord: Ordering[T] = null) : RDD[T] = withScope { if (shuffle) { } else { } } 返回一個經過簡化到numPartitions個分區的新R
相關文章
相關標籤/搜索