根据用户自定义函数类别分为以下三种: (1)UDF(User-Defined-Function) 一进一出 (2)UDAF(User-Defined Aggregation Function) 聚合函数,多进一出 类似于:count/max/min (3)UDTF(User-Defined Table-Generating Functions) 爆炸函数:一进多出 如:lateral view explore() |
自定义UDF函数的步骤
UDF ——(User Defind Function)用户自定义函数 |
1、创建一个Maven工程Hive,导入所需依赖 |
2、创建一个自定义类MyUDF,继承org.apache.hadoop.hive.ql.UDF |
3、编写需求代码;需要实现evaluate函数;evaluate函数支持重载 |
4、打成jar包上传到服务器 /opt/module/jars/udf.jar(自定义位置)中 |
5、将jar包添加到hive的classpath hive (default)> add jar /opt/module/jars/udf.jar; |
6、创建临时函数与开发好的java class关联 hive (default)> create temporary function myudf as "com.bigdata.hive.MyUDF";(函数名myudf自定义) |
7、即可在hql中使用自定义的函数strip hive (default)> select ename, myudf(ename) udfname from emp; |
*8、在hive的命令行窗口删除函数 hive (default)> drop [temporary] function [if exists] [dbname.]function_name; |
注意事项: UDF必须要有返回类型,可以返回null,但是返回类型不能为void; |