菜鸟学hive--UDF函数
2015-07-21 11:57
302 查看
版权声明:本文为博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/cloudrusun/article/details/46984045
package com.xiaocao.getUDF;
import java.util.HashMap;
import java.util.Map;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
/**
* 注意一定要继承UDF
* 同时重写evaluate方法
* 还有,将hadoop-2.6.0\hadoop-2.6.0\share\hadoop\common\hadoop-common-2.6.0.jar
* 还有F:\software_back\hadoop-relation-software\apache-hive-1.2.0-bin\apache-hive-1.2.0-bin\lib\*.jar 全部倒进来
* @author XIAOCAO
*
*/
public class BeatyUDF extends UDF{
private static Map<String, String> levalMap = new HashMap<String, String>();
static{
levalMap.put("35", "A");
levalMap.put("36", "B");
levalMap.put("37", "C");
levalMap.put("38", "D");
levalMap.put("39", "E");
}
Text levalText = new Text();
public Text evaluate(Text leval){
String levalName = levalMap.get(leval.toString());
if(null == levalName){
levalName = "X";
}
levalText.set(levalName);
return new Text(levalText);
}
}
自定义函数调用过程:
1.添加jar包(在hive命令行里面执行)
hive> add jar /root/BraUDF.jar;
2.创建临时函数
hive> create temporary function getBra as 'getUDF.BeatyUDF';
3.像这样调用就好了
select id,name,size,getBra(size) from star_inner;
import java.util.HashMap;
import java.util.Map;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
/**
* 注意一定要继承UDF
* 同时重写evaluate方法
* 还有,将hadoop-2.6.0\hadoop-2.6.0\share\hadoop\common\hadoop-common-2.6.0.jar
* 还有F:\software_back\hadoop-relation-software\apache-hive-1.2.0-bin\apache-hive-1.2.0-bin\lib\*.jar 全部倒进来
* @author XIAOCAO
*
*/
public class BeatyUDF extends UDF{
private static Map<String, String> levalMap = new HashMap<String, String>();
static{
levalMap.put("35", "A");
levalMap.put("36", "B");
levalMap.put("37", "C");
levalMap.put("38", "D");
levalMap.put("39", "E");
}
Text levalText = new Text();
public Text evaluate(Text leval){
String levalName = levalMap.get(leval.toString());
if(null == levalName){
levalName = "X";
}
levalText.set(levalName);
return new Text(levalText);
}
}
自定义函数调用过程:
1.添加jar包(在hive命令行里面执行)
hive> add jar /root/BraUDF.jar;
2.创建临时函数
hive> create temporary function getBra as 'getUDF.BeatyUDF';
3.像这样调用就好了
select id,name,size,getBra(size) from star_inner;
相关文章推荐
- hive udf函数替换特殊字符
- hive-2 自定义函数UDF、UDAF、UDTF介绍及区别
- Hive中添加自定义UDF,UDAF,UDTF等函数jar文件的三种方式
- Hive UDF函数开发及企业规范
- hive UDF自动增长列函数
- hive UDF 自定函数
- Apache Hive 自定义函数UDF函数
- Hive 中的自定义函数(udf,udtf,udaf)
- hive UDF函数开发
- Hive UDF函数开发及企业规范
- hive----自定义UDF 函数-----时间格式化以及取出双引号的代码
- Hive自定义函数UDF示例
- Hive学习之路(五):使用自义定函数UDF完成日志数据统计
- Hive的预定义UDF函数
- Hive自定义函数UDF
- Hive 查看函数(udf)定义及示例
- Hive内置运算函数,自定义函数(UDF)和Transform
- UDF函数在Hive中的使用
- 通过Hive及其Udf函数进行Nginx日志分析
- HIVE 自定义函数之UDF/UDAF/UDTF