当前位置： 首页 >> Hive >> UDF实战

---

UDF实战

2020-10-08 20:44:09 星期四  阅读：2059

---

在公司使用hive时比较复杂的操作或者反复使用的操作就可以自定义一个函数来简化操作，节省开发成本。 注：hive版本1中不能用开窗函数，hive版本2中可以用开窗函数。 ####欲实现功能 时间戳转换为标准时间格式的String字符串 环境准备 把hive的jar包和hadoop的jar包的绝对路径添加到.bash_profile文件里 ####编写Java代码 ``` import java.sql.Date; import java.text.SimpleDateFormat; //想做自定义函数必须加载UDF包 import org.apache.hadoop.hive.ql.exec.UDF; public class TimeFormat extends UDF { //必须复写evaluate方法，方法名固定 public String evaluate(String num){ Date d=new Date(Long.decode(num)); SimpleDateFormat sdf =new SimpleDateFormat("yyyy-MM-dd HH:MM:SS"); return sdf.format(d) ; } } ``` ####编译打包 ```bash /usr/local/src/jdk1.7.0_25/bin/javac TimeFormat.java vim main.mf #Manifest-Version: 1.0 /usr/local/src/jdk1.7.0_25/bin/jar cvfm TF.jar main.mf TimeFormat.class ``` ####注册函数并测试 ``` hive> add jar /home/hadoop/TF.jar; # 创建临时函数（名字随便起）as后面对应jar包中的类名 hive> CREATE TEMPORARY FUNCTION MyTimeFormat AS "TimeFormat"; # 测试 hive> SELECT MyTimeFormat(1524536656909) ; OK 2018-04-24 10:04:909 Time taken 1.025 seconds ```