java—在hive中创建、添加和使用udf

atmip9wb 于 2021-06-03 发布在 Hadoop

关注(0)|答案(1)|浏览(444)

我编写了一个示例udf，用于从配置单元中的表中修剪字符串：

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\u 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

有人能帮忙吗？提前谢谢！

Java hadoop Hive hbase mapreduce

来源：https://stackoverflow.com/questions/32423136/creating-adding-and-using-a-udf-in-hive

1条答案

按热度按时间

jk9hmnmh1#

配置单元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);
    }
}

有关更多信息，请参阅本教程

展开查看全部

赞(0）回复(0）举报 2021-06-03

我来回答

java—在hive中创建、添加和使用udf

1条答案

相关问题

热门标签

最新问答