使用函数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))
常见的操作: