RDD基本转换操做(6)–zip、zipPartitions

zip def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)]java zip函数用于将两个RDD组合成Key/Value形式的RDD,这里默认两个RDD的partition数量以及元素数量都相同，不然会抛出异常。apache scala> var rdd1 = sc.makeRDD(1 to 10,2) rdd1: o

>>阅读原文<<