spark的coalesce和repartition算子管理分區

源碼地址https://github.com/apache/spark/blob/v2.4.0/core/src/main/scala/org/apache/spark/rdd/RDD.scala repartition: / ** *返回一個具有正確numPartitions分區的新RDD。 * *可以增加或減少此RDD中的並行度。在內部,這使用 *重新分配數據的隨機播放
相關文章
相關標籤/搜索