用java建立UDF，並用於Hive

典型代碼以下：

 

導入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 ;

 

大體就是這麼個思路了。