Spark算子执行流程详解之四

17.map /**  * Return a new RDD by applying a function to all elements of this RDD.  */ def map[U: ClassTag](f: T => U): RDD[U] = withScope {   val cleanF = sc.clean(f)   new MapPartitionsRDD[U, T](thi

>>阅读原文<<