首页 > 其他 > 详细

HIVE自定义函数

时间:2018-10-24 22:51:52      阅读:196      评论:0      收藏:0      [点我收藏+]

 


 

一 ,自定义函数的类别

UDF  作用于单个数据行,产生一个数据行作为输出。(数学函数,字符串函数)

UDAF(用户定义聚集函数):接收多个输入数据行,并产生一个输出数据行。(count,max)

二,UDF开发实例

  1,开发一个Java类,继承UDF,并重载evaluate方法(手动重载)。

 1 package cn.itcast.bigdata.udf
 2 import org.apache.hadoop.hive.ql.exec.UDF;
 3 import org.apache.hadoop.io.Text;
 4 
 5 public final class Lower extends UDF{
 6     public Text evaluate(final Text s){
 7         if(s==null){return null;}
 8         return new Text(s.toString().toLowerCase());
 9     }
10 }

  2,打成jar包上传到服务器。

  3,将jar包添加到hive的classpath

hive>add JAR /home/hadoop/udf.jar;

  4,创建临时函数与开发好的java class关联。

create temporary function toprovince as cn.itcast.bigdata.udf.ToProvince;

  5,即可在hql中使用自定义的函数strip 

Select strip(name),age from t_test;

 

 

 

 


 

HIVE自定义函数

原文:https://www.cnblogs.com/songweideboke/p/9846606.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!