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;