Hive的自定义查询函数

偏执的太偏执、 2022-03-17 12:09 601阅读 0赞

# Hive的自定义查询函数 #

**1. Hive的自定义函数（UDF）： User Defined Function**  
可以直接应用于select语句，对查询结构做格式化处理后，再输出内容。

**2. Hive自定义函数的实现细节**  
自定义UDF需要继承org.apache.hadoop.hive.ql.UDF。  
需要实现evaluate函数，evaluate函数支持重载。

**3. Hive自定义函数案例**  
案例一： 拼接两个字符串

package udf;
    
    import org.apache.hadoop.hive.ql.exec.UDF;
    
    public class MyConcatString extends UDF {
    
    	/**
    	 *   自定义的连接函数
    	 * @param a
    	 * @param b
    	 * @return
    	 */
    	public String evaluate(String a, String b) {
    		return a + "***" + b;
    	}
    }

案例二： 判断员工表中工资的级别

package udf;
    
    import org.apache.hadoop.hive.ql.exec.UDF;
    
    /*
     * 	根据员工薪水判断员工级别
    	(*) sal < 1000     ----> Grade A
    	(*) 1000<=sal <3000 ---> Grade B
    	(*) sal >=3000      ---> Grade C
    */
    
    public class CheckSalaryGrade extends UDF {
    	
    	public String evaluate(String salary) {
    		int sal = Integer.parseInt(salary);
    		
    		if (sal < 1000) {
    			return "Grade A";
    		} else if (sal >= 1000 && sal < 3000) {
    			return "Grade B";
    		} else {
    			return "Grade C";
    		}
    	}
    }

**4、Hive自定义函数的部署**

*  把程序打包放到目标机器上去
 *  进入hive客户端，添加jar包：

hive> add jar /root/temp/udf.jar;

*  创建临时函数：

hive> create temporary function myconcat as 'udf.MyConcatString';
    hive> create temporary function checksal as 'udf.CheckSalaryGrade';

**5、Hive自定义函数的调用**

*  查询HQL语句：

hive> select myconcat(ename,job) from emp;
    hive> select ename,sal,checksalary(sal) from emp;

*  销毁临时函数：

hive> DROP TEMPORARY FUNCTION checksalary;