Spark RDD建立操做

從集合中建立RDD parallelize def parallelize[T](seq: Seq[T], numSlices: Int = defaultParallelism)(implicit arg0: ClassTag[T]): RDD[T] 從一個Seq集合建立RDD。python 參數1： Seq 集合， 必需要有 參數2： 分區數，默認爲該Application分配的資源的CPU核

>>阅读原文<<