Hive 创建自定义函数（UDF）

package com.example.hive.udf;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public final class Lower extends UDF {
 public Text evaluate(final Text s) {
 if (s == null) { return null; }
 return new Text(s.toString().toLowerCase());
 }
}

--添加jar
hive> add jar /tmp/my_jar.jar;
--查看该Hive会话中添加的jar
hive> list jars;

hive> CREATE FUNCTION myfunc AS 'myclass' USING JAR 'hdfs:///path/to/jar';

create temporary function my_lower as'com.example.hive.udf.Lower';

select my_lower(title), sum(freq) from titles group by my_lower(title);