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

>>阅读原文<<