当前位置:   article > 正文

Hive 自定义UDF函数_hive udf自定义函数

hive udf自定义函数

在使用hive中,有时要根据业务需求自定义一些函数,下面是自定义函数的步骤
1.新建一个maven项目,在项目的pom文件中引入依赖

  1. <dependency>
  2. <groupId>org.apache.hive</groupId>
  3. <artifactId>hive-exec</artifactId>
  4. <version>3.1.2</version>
  5. </dependency>

2.新建一个class,继承UDF,并重写evaluate()方法,下面是一个增加字段前缀的方法,具体实现参考如下代码

  1. import org.apache.hadoop.hive.ql.exec.Description;
  2. import org.apache.hadoop.hive.ql.exec.UDF;
  3. import java.util.Random;
  4. @Description(
  5. name = "min",
  6. value = "_FUNC_(expr) - add a number and '_' before the expr"
  7. )
  8. public class AddPrefixUDF extends UDF {
  9. public String evaluate(String input){
  10. Random random = new Random();
  11. int num = random.nextInt(10);
  12. return num + "_" + input;
  13. }
  14. publi
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小惠珠哦/article/detail/984895
推荐阅读
相关标签
  

闽ICP备14008679号