java - Apache pig 脚本，错误 1070 : Java UDF could not resolve import

Question

我正在尝试编写一个 Java UDF，其最终目标是扩展/覆盖 PigStorage 的加载方法以支持采用多行的条目。

我的 pig 脚本如下:

REGISTER udf.jar;
register 'userdef.py' using jython as parser;
A = LOAD 'test_data' USING PigStorage() AS row:chararray;
C = FOREACH A GENERATE myTOKENIZE.test();
DUMP D;

udf.jar 看起来像:

udf/myTOKENIZE.class

myTOKENIZE.java 导入 o​​rg.apache.pig.* 并扩展 EvalFunc。测试方法只返回一个 Hello world 字符串。

我遇到的问题是，当我尝试调用 myTOKENIZE 类的方法 test() 时，出现错误 1070:错误 1070:无法使用导入解析 myTOKENIZE.test:[, java.lang., org. apache.pig.builtin., org.apache.pig.impl.builtin.] 想法？

Answer 1

当你的 UDF 扩展 EvalFunc 时，我应该在 myTOKENIZE 类中有一个名为 exec() 的方法。

您的 pig 代码将如下所示:

C = FOREACH A GENERATE udf.myTOKENIZE(*);

请阅读http://pig.apache.org/docs/r0.7.0/udf.html#How+to+Write+a+Simple+Eval+Function

希望对您有所帮助。