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
相关文章
相关标签/搜索