- UDF:用户定义(普通)函数,只对单行数值产生作用;
- UDF只能实现一进一出的操作。
- –java代码
- import org.apache.hadoop.hive.ql.exec.UDF;
- public class MyUDF extends UDF {
- public int evaluate(int data){
- return data + 5;
- }
- }
- –打包jar包
- –jar包添加到hdfs上
- hdfs dfs -put linux路径 hdfs路径
- –添加jar包
- add jar hdfs:///lyc/CcTest-1.0-SNAPSHOT.jar;
- –创建临时函数
- create temporary function cc as ‘com.lyc.MyUDF’;
- –销毁临时函数
- DROP TEMPORARY FUNCTION cc;