• 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;

作者 admin

张宴银,大数据开发工程师

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注