分享

hive UDF

原数据:(NaNNaNNaN234443,iptv7710679406)
(NaNNaNNaN234141,iptv7810273420)
(NaNNaNNaN233922,iptv7710682349)
(NaNNaNNaN232054,iptv7760711422)
(NaNNaNNaN231453,iptv7750612840)
(NaNNaNNaN231252,iptv7790553708)
(NaNNaNNaN231057,iptv7710686875)
(NaNNaNNaN230821,iptv7840651606)
(NaNNaNNaN230756,iptv7790701101)
(NaNNaNNaN230120,iptv7800247742)

我想把数据切分成

NaNNaNNaN234141 iptv7810273420
NaNNaNNaN233922 iptv7710682349
NaNNaNNaN232054 iptv7760711422
NaNNaNNaN231453 iptv7750612840
NaNNaNNaN231252 iptv7790553708
NaNNaNNaN231057 iptv7710686875
NaNNaNNaN230821 iptv7840651606
NaNNaNNaN230756 iptv7790701101
NaNNaNNaN230120 iptv7800247742

用udf该怎们做?????




已有(4)人评论

跳转到指定楼层
逆光之处是快乐 发表于 2017-11-29 14:23:58
最好出来时两个字段的值
回复

使用道具 举报

desehawk 发表于 2017-11-29 15:17:01
逆光之处是快乐 发表于 2017-11-29 14:23
最好出来时两个字段的值

跟这个是不是一样的。
Spark  scala
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23419
已经有udf了吗?
还是完全没有,弄懂整个流程?

回复

使用道具 举报

wangxiaojian 发表于 2017-11-30 08:49:30
用UDTF函数,输入一个字段 输出两个字段
回复

使用道具 举报

sstutu 发表于 2017-12-1 11:39:21
udf其实也是用Java实现的,然后注册在hive里面,在写sql的时候直接调用。整个流程是这样的。
回复

使用道具 举报

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

本版积分规则

关闭

推荐上一条 /2 下一条