Hive进阶之UDF开发（Java版）

小咪咪 2022-11-29 11:49 234阅读 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 条评论，234人围观）

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

相关阅读

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

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

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

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

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

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

相关 Hive UDF整理

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

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

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

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

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

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

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

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

相关 Hive进阶之Hive数据导入

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

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

相关 HIVE UDF（1）

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

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

相关 JAVA之JDBC工具类-Mysql（进阶版）

接着上一次JAVA之JDBC工具类简单版，新手的话可以先看看[简单版][Link 1]（点击简单版即可跳转的简单版博客）再回来看这个进阶版。还是那句话，不对之处还请各位不吝赐教

曾经终败给现在/ 2022年03月27日 09:40/ 0 赞/ 609 阅读

相关 Hive UDF开发案例

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

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

相关 hive进阶学习

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

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