转换字符串为大写
package com.hive.myhive.udf;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public class Upper extends UDF {
public Text evaluate(Text s)
{
if(s==null)
return null;
return new Text(s.toString().toUpperCase());
}
}
打包
mkdir Upper 创建一个目录
javac -d Upper Upper.java 编译到这个目录中
jar -cvf Lower.jar -C Lower/ . 打包
在hive中添加包
hive> add jar /usr/hive/mysrc/Upper.jar;
Added /usr/hive/mysrc/Upper.jar to class path
在hive中创建函数
hive> create temporary function my_upper as ‘ com.hive.myhive.udf.upper’;
使用函数
hive> select my_upper(name) from tmp_table;