Hive自定义函数

配置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

上一篇:上汽增资控股后,中海庭首发声:备战自动驾驶,高精地图面临的机遇和挑战


下一篇:关于在.Net开发中使用Sqlite的版本选择问题