Key-Value類型的RDD的建立及基本轉換(1)

1. 建立一個基本的key-value的RDD scala> val kvPairRDD =      |   sc.parallelize(Seq(("key1", "value1"), ("key2", "value2"), ("key3", "value3"))) kvPairRDD: org.apache.spark.rdd.RDD[(String, String)] = Parallel
相關文章
相關標籤/搜索