首页 > 其他 > 详细

Hive自定义函数UDF示例

时间:2015-08-29 11:01:36      阅读:155      评论:0      收藏:0      [点我收藏+]
简单自定义函数只需继承UDF类,然后重构evaluate函数即可
LowerCase.java:
package com.example.hiveudf;
import org.apache.hadoop.hive.ql.exec.UDF;
public final class LowerCase extends UDF { 
  public String evaluate(final String s) {
    if (s == null) { return null; }
    return new String(s.toString().toLowerCase());
  }
}
依赖包只有hive-exec-0.13.1.jar,MANIFEST.MF文件为:
Manifest-Version: 1.0
Class-Path:  
  lib/hive-exec-0.13.1.jar
Main-Class: com.example.hiveudf.LowerCase
将上述java文件导出为test.jar, 上传到hive安装主机的一个目录上,如/usr/hive/test.jar
在hive中执行测试:
hive> add jar /usr/hive/test.jar;
hive>create temporary function mylower as ‘com.example.hiveudf.LowerCase‘;  
hive>select mylower (‘ABCD‘);
输出:abcd
删除临时函数:
hive>drop temporary function mylower;

Hive自定义函数UDF示例

原文:http://www.cnblogs.com/zhaohz/p/4768568.html

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