Spark scala

查看数: 5175 | 评论数: 2 | 收藏 0
关灯 | 提示:支持键盘翻页<-左 右->
    组图打开中,请稍候......
发布时间: 2017-11-29 11:42

正文摘要:

这个括号该怎们去掉(20170701001630,iptv7710965932)   ,我想他在hdfs 上是两个字段

回复

desehawk 发表于 2017-11-29 15:09:41
将(datatime,iptv
改成这样的
map(line=>
     | {val filed=line.split("\\|")
     | val datatime=filed(2)
     | val iptv=filed(1)
     | datatime+","+iptv})


最后输出结果如下:
1.jpg
逆光之处是快乐 发表于 2017-11-29 11:45:17
00|iptv2014050901|20171123120126|08
00|iptv2014070803|20171123120127|08
00|iptv2014030803|20171123120132|01
00|iptv2014050901|20171123120156|08
00|iptv2014070803|20171123120157|08
00|iptv2014030803|20171123120202|01
00|iptv2014050901|20171123120226|08
00|iptv2014070803|20171123120227|08
00|iptv2014030803|20171123120232|01
00|iptv2014050901|20171123120256|08
00|iptv2014070803|20171123120257|08
00|iptv2014030803|20171123120302|01
00|iptv2014050901|20171123120326|08
00|iptv2014070803|20171123120327|08
00|iptv2014030803|20171123120332|01
关闭

推荐上一条 /2 下一条