cerisier · April 10, 2016 14:29
diff --git a/map.scala b/map.scala
 /**
 * 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](this, (context, pid, iter) => iter.map(cleanF))
 }
	/**
	* 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](this, (context, pid, iter) => iter.map(cleanF))
	}