用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 ;

大致就是这么个思路了。