在 Hive 中创建、添加和使用 UDF

Question

我已经编写了一个示例 UDF 来从 hive 中的表中修剪一个字符串：

package anoop;


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

import org.apache.hadoop.io.Text;

public class DataTrim  extends UDF{

String trimmed;

public Text trim(Text incomingData){

    trimmed= incomingData.toString().trim();

    return new Text(trimmed);
}


}

我为此“trim_string.jar”创建了一个 jar，并将其保存到 hive lib 文件夹。 现在我跑了：

add jar '~/hive-1.2.1/lib/trim_string.jar';  (success)

现在我跑

 create temporary function trimmed1 as 'anoop.DataTrim';

但我收到以下错误：

FAILED: Class anoop.DataTrim does not implement UDF, GenericUDF, or UDAF
FAILED: Execution Error, return code 1 from     org.apache.hadoop.hive.ql.exec.FunctionTask

有人可以帮忙吗？提前致谢！

Answer 1

hive UDF 必须包含名为 evaluate 的函数。将名为trim的函数重命名为evaluate

公共文本评估（文本传入数据）

注意：String trimmed 不需要作为类成员。您可以将其移动为局部变量。

package anoop;


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

public class DataTrim  extends UDF{

    public Text evaluate(Text incomingData){
        String trimmed;
        trimmed= incomingData.toString().trim();
        return new Text(trimmed);
    }


}

更多信息请参考tutorial