spark对笛卡尔乘积的优化

import org.apache.spark.rdd._ def combs(rdd:RDD[String]):RDD[(String,String)] = { val count = rdd.count if (rdd.count < 2) { sc.makeRDD[(String,String)](Seq.empty) } else if (rdd.count == 2) { val val

>>阅读原文<<