0

我有一个使用以下代码创建的配置单元表：

CREATE EXTERNAL TABLE IPRegions (
    ip STRING,
    -- other fields don't matter 
)

我需要使用自写的 UDFip以相反的顺序输出每个（是的，这是一个非常简单的问题）。SELECT ip FROM IPRegions为此，我编写了以下 UDF：

public class ReverseUDF extends UDF {
    /**
     * Reversing of a string.
     * @param str input string
     * @return reversed string
     */
    public String reverse(String str){
        return new StringBuilder(str).reverse().toString();
    }
}

比我jar用这个 UDF 构建 -file 并编写这样的查询：

USE my_base;
add jar Reverser/jar/Reverser.jar;
create temporary function reverse as 'com.lab4udf.ReverseUDF';

select reverse(ip)
from IPRegions;

但我咳嗽了一个例外：

FAILED: SemanticException [Error 10014]: Line 3:7 Wrong arguments 'ip': No matching method for class com.lab4udf.ReverseUDF with (string).

正如我在许多示例中看​​到的，在 UDF 中经常使用hadoop 类型而不是普通的 java 类型。比我重写并重建我的 UDF：

public Text reverse(Text str){
        return new Text(new StringBuilder(str.toString())
                .reverse().toString());
}

但这没有帮助。那么，我的错误在哪里？我应该如何更改 UDF 或查询来解决这个问题？

4

1 回答 1

0

所以，我解决了我的问题。

必须只调用实现 UDF 功能的方法（例如reverse()在我的 UDF 中） ，而不能调用evaluate()其他任何方法！

于 2015-04-19T00:05:43.473 回答