hive创建自定义udf分析

熊孩纸 阅读:150 2021-11-03 14:32:22 评论:0
本文章主要介绍了hive创建自定义udf,具有不错的的参考价值,希望对您有所帮助,如解说有误或未考虑完全的地方,请您留言指出,谢谢!

实现一个base64加密函数

1、实现java类

package com.zheng.udf; 
 
import java.util.Base64; 
import org.apache.hadoop.hive.ql.exec.UDF; 
 
public class UDFBase64Encoder extends UDF { 
    public String evaluate (String str) { 
        return Base64.getEncoder().encodeToString(str.getBytes()); 
    } 
} 

2、将代码打成jar包,包名test.jar

3、上传到hive所在服务器,路径为/home/admin/test.jar

4、执行hive

#上传test.jar 
hive> add jar /home/admin/test.jar; 
Added [/home/admin/test.jar] to class path 
Added resources: [/home/admin/test.jar] 
 
 
#创建base64Encode函数 
hive> create temporary function base64Encode as 'com.zheng.udf.UDFBase64Encoder'; 
OK 
Time taken: 1.822 seconds 
 
#测试 
hive> select base64Encode('test'); 
OK 
dGVzdA== 
Time taken: 1.214 seconds, Fetched: 1 row(s)

标签:Hive
声明

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

发表评论
搜索
KIKK导航

KIKK导航

排行榜
关注我们

一个IT知识分享的公众号