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若是

>>阅读原文<<