典型代碼如下:
導入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 ;
大致就是這么個思路了。