首页 > 其他 > 详细

KeyValue对RDDs

时间:2018-11-25 18:30:56      阅读:177      评论:0      收藏:0      [点我收藏+]

创建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

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!