UDF函数可以直接应用于select语句，对查询结构做格式化处理输出内容。自定义UDF需要继承org.apache.hadoop.hive.ql.UDF,实现evaluate函数。

自定义udf函数步骤：

•   1.继承UDF类
•   2.重写evaluate方法
•   3.把项目打成jar包
•   4.hive中执行命令add jar /home/jrjt/dwetl/PUB/UDF/udf/GetProperty.jar;
•   5.创建函数create temporary function get_pro as 'jd.Get_Property'//jd.jd.Get_Property为类路径;

永久udf函数创建：

•   1、hdfs dfs -put udftimestamp.jar /udf/
•   2、add jar hdfs://nameservice1:8020/udf/udftimestamp.jar;
•   3、CREATE FUNCTION dm_lots.udftimestamp AS 'mytimestamp.MyUDFTimestamp' using jar 'hdfs://nameservice1:8020/udf/udftimestamp.jar';

删除udf函数

drop function dm_lots.udftimestamp;

查看udf函数

show functions

例1：日志切割

import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public class SalaryUDF extends UDF{
public Text evaluate(Text salaryText){
//1.if salary is null
if (salaryText == null) {
return null;
}
String salaryStr = salaryText.toString();
//2.if salary is not double type
double salary = 0.0;
try {
salary = Double.valueOf(salaryStr);
} catch (NumberFormatException e) {
e.printStackTrace();
return null;
}
Text text = new Text();
//3.panduan salary return string
if (salary > 10000) {
text.set("you are rich");
return text;
}else if (salary <= 10000 && salary > 5000) {
text.set("income is normal");
return text;
}else {
text.set("income is pool");
return text;
}
}
}

例2：日期转化

package com.rainbow.udf;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public class TestDate extends UDF{
private SimpleDateFormat inputdateFormat = new SimpleDateFormat("dd/MM/yyyy:HH:mm:ss",locale.ENLISH);
private SimpleDateFormat outputdateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
public Text exvaluate(Text input){
Text output = new Text();
if(null==input){
return null;
}
if(null==input.toString()){
return null;
}
try {
String inputDate=input.toString().trim();
Date perseDate = inputdateFormat.parse(inputDate);
String outputDate = outputdateFormat.format(perseDate);
output.set(outputDate);
}catch(Exception e){
e.printStackTrace();
return output;
}
return output;
}
}

打jar包 
上传到hdfs
CREATE FUNCTION [db_name.]function_name AS class_name [USING JAR|FILE|ARCHIVE'file_uri' [, JAR|FILE|ARCHIVE'file_uri'] ];

【Hive】Hive常用函数（UDF篇）
 

Hive的函数分为三类，分别是UDF、UDAF、UDTF，简单区分这三类函数就是，UDF是单行输入，单行输出；UDAF是多行输入，单行输出；UDTF是单行输入，多行或多列输出。

另：所有的hive函数，都可以使用desc function 函数名 查看使用方法，若想查看更详细的使用方法，则可以使用desc function extended 函数名

UDF

字符串类

日期类

 集合类

条件类

 Hive官网UDF

最后

以上就是鲜艳战斗机为你收集整理的【Hive】函数（UDF篇）【Hive】Hive常用函数（UDF篇）  的全部内容，希望文章能够帮你解决【Hive】函数（UDF篇）【Hive】Hive常用函数（UDF篇）  所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。