Spark算子講解(一)

1：Zip算子java def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)] 將兩個RDD作zip操做，若是當兩個RDD分區數目不同的話或每個分區數目不同的話則會異常。apache 例如：緩存 val rdd1 = sc.parallelize(Array(1,2,3,4,5,6),2) val rdd2 = sc.p

>>阅读原文<<