hive 自定义函数

 

1.编写java类,继承UDF,注意方法名需要覆盖evaluate方法.之前测试时发现方法名可以任意,后来发现还是不行,所以还是用evalute这个方法名吧

import org.apache.hadoop.hive.ql.exec.UDF;

public class MyLower extends UDF {
    
    public String evaluate (final String s) {
        
        if (s == null) {
            return null;
        }
        
        return s.toString().toLowerCase();
    }
}

2.打成jar包上传到linux上

 

3,启动hive后进行关联

add jar /opt/module/data/jar/test.jar;

注意如果你想对jar替换,最好先delete jar xxx,直接add不会进行覆盖,这样你仍然使用的是旧的jar

 

4.创建函数

create temporary function test as "hive.MyLower";

as之后是你编写的类的全限定名称

 删除临时函数 drop temporary function xxx;

5.测试