典型代碼如下：

?

導入UDF類：

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());

　　　　}

　　}

}

導出jar文件。

?

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

在hive中使用add命令：

add /path/to/UpperCaseUDF.jar

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

?

驗證這個function是否已經成功添加并且功能如預期。

select ucase(column) from table ;

?

大致就是這么個思路了。

?

轉載于:https://www.cnblogs.com/xiamodeqiuqian/p/4887325.html

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。