Hive 自定义函数

package com.hive.custom;

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

public class XiaoUDF extends UDF {

    /**
     *  值加1000
     * @param i
     * @return val
     */
    public IntWritable evaluate(final IntWritable i) {
     int val= i.get();
     val+=1000;
        return new IntWritable(val);
      }
}

add jar /root/udfxiao.jar；
//add jar you.jar

create temporary function fei  as ‘com.hive.custom.XiaoUDF‘;
//fei:注册的函数名
//com.hive.custom.XiaoUDF 注册函数的全类名

select fei(id) from test;

create  function testdb.peng  as ‘com.hive.custom.XiaoUDF‘;
//testdb 注册永久函数的数据库

CREATE FUNCTION fei AS ‘com.hive.custom.XiaoUDF‘ USING JAR ‘hdfs:///udfxiao.jar‘;
// fei 注册的函数名
//com.hive.custom.XiaoUDF  函数的全内名
//hdfs:///udfxiao.jar   hdfs上根目录下的jar

drop temporary function if exists fei;