0
点赞
收藏
分享

微信扫一扫

1006-Hive的UDF操作

梦为马 2023-04-03 阅读 55



2、编写UDF函数的时候需要注意一下几点:

a)自定义UDF需要继承org.apache.hadoop.hive.ql.UDF。
b)需要实现evaluate函数,evaluate函数支持重载。

          


3、步骤


a)把程序打包放到目标机器上去;
b)进入hive客户端,添加jar包:hive>add jar /run/jar/udf_test.jar;
c)创建临时函数:hive>CREATE TEMPORARY FUNCTION add_example AS 'hive.udf.Add';
d)查询HQL语句:



SELECT add_example(8, 9) FROM scores;



SELECT add_example(scores.math, scores.art) FROM scores;



SELECT add_example(6, 7, 8, 6.8) FROM scores;



e)销毁临时函数:hive> DROP TEMPORARY FUNCTION add_example;


注:UDF只能实现一进一出的操作,如果需要实现多进一出,则需要实现UDAF





4、若采用maven工程方式创建UDF函数,需要引入下面的包



< dependency >
       < groupId >  org.apache.hive </ groupId  >
      < artifactId >  hive-exec </ artifactId  >
      < version >  0.12.0 </  version >
</ dependency >













举报

相关推荐

0 条评论