Hive UDF 创建

要创建 UDF，我们需要扩展 UDF（org.apache.hadoop.hive.ql.exec.UDF）类并实现 evaluate 方法。

一旦编译了 UDF 并构建了 JAR，我们需要将 jar 添加到 hive 上下文以创建临时/永久函数。

import org.apache.hadoop.hive.ql.exec.UDF;    

class UDFExample extends UDF {
  
  public String evaluate(String input) {
    
    return new String("Hello " + input);
  }
}

hive> ADD JAR <JAR NAME>.jar;
hive> CREATE TEMPORARY FUNCTION helloworld as 'package.name.UDFExample';
hive> select helloworld(name) from test;