典型代碼如下：

?

導(dǎo)入U(xiǎn)DF類：

import org.apache.hadoop.hive.ql.exec.UDF;

public class UpperCassUDF extends UDF{

　　public String evaluate(String input){

　　　　if(input==null){

　　　　　　return null;

　　　　}

　　　　else{

　　　　　　return new String(input.toUpperCase());

　　　　}

　　}

}

導(dǎo)出jar文件。

?

接下來的問題是，怎樣把這個(gè)類添加到hive中呢？

在hive中使用add命令：

add /path/to/UpperCaseUDF.jar

create temporary function ucase as 'package.name.UpperCaseUDF';

?

驗(yàn)證這個(gè)function是否已經(jīng)成功添加并且功能如預(yù)期。

select ucase(column) from table ;

?

大致就是這么個(gè)思路了。

?

轉(zhuǎn)載于:https://www.cnblogs.com/xiamodeqiuqian/p/4887325.html

總結(jié)

以上是生活随笔為你收集整理的用java创建UDF，并用于Hive的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。