val rdd = sc.parallelize(List((1,1),(2,1),(3,1),(3,4))) ... 以分区为单位执行mapdef mapPartitions[U: ClassTag](f: Iterator[T] => Iterator[U], ...
確定! 回上一頁