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;