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

>>阅读原文<<