parallelize中指定partition個數的詳解

val rdd  = sc.parallelize(List(1,2,3,4,5,6,7),3)生成RDD的時候，RDD中的partition是如何決定的ide def parallelize[T: ClassTag](spa       seq: Seq[T],orm       numSlices: Int = defaultParallelism): RDD[T]ci numSlices若是

>>阅读原文<<