package udf; import org.apache.hadoop.hive.ql.exec.UDF; public class helloudf extends UDF{ public String evaluate(String str){ try { return "HelloWorld " + str; } catch (Exception e) { // TODO: handle exception return null; } } } 上面是一个java project 写的 udf 程序的意思大家应该都明白 打包成jar: 用fat jar 博客之前发过jar包了，然后导出成jar 传到Linux本地目录 进入hive add jar /home/hadoop/udf_1_fat.jar; //注意，这个地址为Linux本地地址，不是hdfs地址 传到hdfs是接收不到的 除非你加上hdfs链接(没有测试) CREATE TEMPORARY FUNCTION helloworld AS 'udf.helloudf' show functions 可以看到所有支持的方法，里面会有helloworld 找一个表，里面有点数据的 我这边找的一个表，我查出来的数据为： hive> select * from hive1 limit 10; OK 1 百花家园 张云龙 18001295207 155 2室1厅1卫 94 2/5层 南北 sina 河北链家地 2 中国铁建原香小镇 高伟 13501061874 210 3室2厅1卫 115 6/6层 南北 sina 凯利门 3 金泰城丽湾 马丰收 18210989857 1200 5室3厅3卫 258 18/19层 南北 sina 21世纪 4 恋日绿岛 于洪梁 13366126543 430 3室2厅2卫 149 2/4层 南北 sina 如一房产 5 怡海花园恒泰园 史润生 18401296028 520 2室2厅2卫 136 15/28层 西 sina 我爱我家 6 高教新城观宇园 张超 18910750910 180 2室1厅1卫 89 14/18层 南北 sina 晨建顺房屋 7 东润枫景 孙心源 13501365333 380 2室1厅1卫 91 1/20层 东南 sina 我爱我家 8 北苑家园望春园 刘韬 18311385981 245 1室1厅1卫 69 17/25层 东南 sina 城承物业 9 中央公园广场 吕德辉 15010507970 5800 1室0厅0卫 672 2/26层 南 sina 华清永泰 10 上上城第二季 杨瑞平 15001210716 200 4室1厅2卫 155 6/15层 南北 sina 河北链家地 字段对应就不说了 下面就是结果了 hive> select helloworld(hive1.large) from hive1 limit 10; OK HelloWorld 94 HelloWorld 115 HelloWorld 258 HelloWorld 149 HelloWorld 136 HelloWorld 89 HelloWorld 91 HelloWorld 69 HelloWorld 672 HelloWorld 155 Time taken: 0.131 seconds, Fetched: 10 row(s) hive> select helloworld(hive1.price) from hive1 limit 10; OK HelloWorld 155 HelloWorld 210 HelloWorld 1200 HelloWorld 430 HelloWorld 520 HelloWorld 180 HelloWorld 380 HelloWorld 245 HelloWorld 5800 HelloWorld 200 Time taken: 0.111 seconds, Fetched: 10 row(s) hive> select helloworld(hive1.id) from hive1 limit 10; OK HelloWorld 1 HelloWorld 2 HelloWorld 3 HelloWorld 4 HelloWorld 5 HelloWorld 6 HelloWorld 7 HelloWorld 8 HelloWorld 9 HelloWorld 10 Time taken: 0.115 seconds, Fetched: 10 row(s) ok，大家都懂什么意思了吧