spark學習-SparkSQL--09-一些函數的使用

1。parallelizePairs餘parallelizejava /** Distribute a local Scala collection to form an RDD. */ def parallelizePairs[K, V](list: java.util.List[Tuple2[K, V]], numSlices: Int) : JavaPairRDD[K, V] = {

>>阅读原文<<