典型代码如下:
导入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 ;
大致就是这么个思路了。
时间: 2024-11-10 18:10:23