分享

Spark scala

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

2345截图20171129114047.png

已有(2)人评论

跳转到指定楼层
逆光之处是快乐 发表于 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
回复

使用道具 举报

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
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条