【Spark学习笔记】KeyValue对RDDs

创建KeyValue对RDDs：使用map()函数，返回key/value对 例如，包含数行数据的RDD，把每行数据的第一个单词作为keys val rdd2=rdd.map(line=>(line.split(" ")(0),line)) image.png val rdd3=sc.parallelize(Array((1,2),(3,4),(3,6))) (1,2) (3,4) (3,6) v

>>阅读原文<<