Hive(八)之UDF函数

自定义函数 -> UDF

01. 写一个函数实现字段属性值的大小写转换

在pom.xml文件中添加hive依赖包

<dependency>
  <groupId>org.apache.hive</groupId>
  <artifactId>hive-jdbc</artifactId>
  <version>0.13.1</version>
</dependency> 
   
<dependency>
  <groupId>org.apache.hive</groupId>
  <artifactId>hive-exec</artifactId>
  <version>0.13.1</version>
</dependency>

在maven项目中新建ToLowCase 类

package com.darrenzhang.hivedemo.hive_demo;

import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;

public class ToLowCase extends UDF{
    
    public Text evaluate(Text str){
        if(str == null) return null;
        if(str != null&& str.toString().length() <= 0) return null;
        return new Text(str.toString().toLowerCase());  
    }
    
    public static void main(String[] args){
        System.out.println(new ToLowCase().evaluate(new Text(args[0])));
    }
}

将其打成jar包


导出为jar文件
jar包的存放文职

然后一直next,finish就可以了。
打成jar包之后,要把这个jia包添加到hive的临时列表中


把jar包发布到hive的临时列表中
把jar包发布到hive的临时列表中
查询是否添加成功
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容