Hive进阶之UDF开发（Java版）

小咪咪 2022-11-29 11:49 253阅读 0赞

以下演示如何使用Java编写Hive UDF。

## 添加依赖 ##

**JUnit**

<dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.13</version>
        <scope>test</scope>
    </dependency>

**Hive**

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

## 代码实现 ##

单独一个class，需要继承`UDF`，再添加一个特定的方法`evaluate`，入参可以为多个，出来推荐一个简单的类型，比如`String`, `Integer`。

import org.apache.hadoop.hive.ql.exec.UDF;
    
    public class UdfDemo extends UDF { 
    
        public String evaluate(int year, int month, int day) { 
            return String.format("%d-%02d-%02d", year, month, day);
        }
    }

## 单元测试 ##

import org.junit.Before;
    import org.junit.Test;
    
    public class UdfDemoTest { 
    
        private UdfDemo udfDemo;
    
        @Before
        public void init() { 
            udfDemo = new UdfDemo();
        }
    
        @Test
        public void evaluate() { 
            System.out.println(udfDemo.evaluate(2020, 8, 20));
        }
    }

输出结果

2020-08-20

## 打包 ##

mvn clean package

这里会生成一个jar包：udf-demo-1.0.jar；后面我们会用到。

## 在SQL中使用 ##

通过add jar命令设置UDF文件的路径，可以是绝对路径，它也可以是相对路径。

add jar './udf-demo-1.0.jar';
    
    create temporary function udf_demo as 'com.domain.tech.test.udf.UdfDemo';
    
    select udf_demo(2020, 10, 1);

输出结果

2020-10-01

发表评论取消回复

表情：

评论列表（有 0 条评论，253人围观）

还没有评论，来说两句吧...

相关阅读

相关 UDF开发入门（python udf、hive udf）

开发前的声明 udf开发是在数据分析的时候如果内置的函数解析不了的情况下去做的开发，比方说你只想拆分一个字段，拼接一个字段之类的，就不要去搞udf了，这种基本

港控/mmm°/ 2023年07月06日 08:56/ 0 赞/ 115 阅读

相关 Hive进阶之UDF开发（Python版）

以下演示如何使用Python编写Hive UDF。编写UDF 这个DEMO是将第列的值转换成字符串，然后再加上前缀和后缀`@`； import sys

╰半夏微凉°/ 2022年11月29日 11:51/ 0 赞/ 204 阅读

相关 Hive进阶之UDF开发（Java版）

以下演示如何使用Java编写Hive UDF。添加依赖 JUnit <dependency> <groupId>junit</groupId

小咪咪/ 2022年11月29日 11:49/ 0 赞/ 254 阅读

相关 Hive UDF整理

Hive UDF整理字符串函数字符串长度函数：length <table> <tbody> <tr> <td> <p><span

待我称王封你为后i/ 2022年09月26日 03:30/ 0 赞/ 210 阅读

相关 Java操作Hive系列1-Hive UDF

文章目录一.创建Hive工程 1.1 新建Java工程 1.2 将Hive的lib下所有jar包放到lib目录下 1.3

男娘i/ 2022年08月31日 15:24/ 0 赞/ 178 阅读

相关 Hive进阶之Hive的数据查询

如何让简单的查询不生成mapreduce可以做以下三种操作的任意一种操作 ![Center][] ![Center 1][]

野性酷女/ 2022年06月13日 04:40/ 0 赞/ 315 阅读

相关 Hive进阶之Hive数据导入

使用load语句导入数据 \-语法： LOAD DATA \[LOCAL\] INPATH 'filepath' \[OVERWRITE\] INTO TABLE ta

墨蓝/ 2022年06月13日 03:53/ 0 赞/ 546 阅读

相关 HIVE UDF（1）

字符串函数字符串长度函数：length <table> <tbody> <tr> <td>语法: length(string A) <p></p

清疚/ 2022年03月28日 15:36/ 0 赞/ 286 阅读

相关 Hive UDF开发案例

创建Maven项目，添加依赖  <properties>

不念不忘少年蓝@/ 2022年02月04日 19:39/ 0 赞/ 239 阅读

相关 hive进阶学习

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 创建数据库 create database

拼搏现实的明天。/ 2022年01月14日 14:35/ 0 赞/ 284 阅读