配置pom.xml引入基础包
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-jdbc</artifactId>
<version>2.3.8</version>
</dependency>
重写UDF的evaluate方法
public class DemoUDF extends UDF {
public String evaluate(String data) {
return data + "-12345678";
}
}
输出jar包
Demo-1.0.0.jar
临时发布
(1)进入Hive命令行。
(2)添加Jar包: add jar /home/hadoop/jobs/Demo-1.0.0.jar;
(3)创建临时方法: create temporary function demo1 as 'com.xxx.xxx.DemoUDF';
(4)使用临时方法: select demo1('MyName is : ');
永久发布
(1)上传HDFS: hadoop fs -put Demo-1.0.0.jar /user/hadoop
(2)创建永久方法: create function demo1 as 'com.xxx.xxx.DemoUDF' using jar 'hdfs://ns/user/hadoop/Demo-1.0.0.jar';
(3)使用永久方法: select demo1('MyName is : ');
(4)输出: MyName is : -12345678