KeyValue对RDDs

标签：9.png   png   info   line   创建   一个   rdd   技术   操作   

创建KeyValue对RDDs

使用函数map，返回keyvalue对
例如，包含数行数据的RDD，那每行的第一个单词作为keys。
sparl.txt中的内容如下：
hello !
hello world
hello spark

val rdd = sc.textFile("spark.txt")
val rdd2 = rdd.map(line=>(line.split(" ")(0),line))

常见的操作：

KeyValue对RDDs

标签：9.png   png   info   line   创建   一个   rdd   技术   操作   

原文地址：https://www.cnblogs.com/twodoge/p/10016144.html