Pig脚本使用XPathAll和Python UDF

Question

我正在尝试编写一个Pig脚本，它将一个XML文件作为输入，并在运行某些UDF后返回文件中某个子节点的所有值。这是我运行该脚本：

REGISTER 'piggybank-0.15.0.jar'; 
REGISTER 'function.py' USING streaming_python as myFunc; 
DEFINE XPathAll org.apache.pig.piggybank.evaluation.xml.XPathAll(); 
A = LOAD 'file.xml' using org.apache.pig.piggybank.storage.XMLLoader('Parent') as (x:chararray); 
B = FOREACH A GENERATE XPathAll(x, 'Parent/Child', true, true) as (y:tuple); 
C = FOREACH B myFunc.func(y); 
DUMP C; 

我想打电话给UDF后得到以下错误：

ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200: <line 10, column 14> Syntax error, unexpected symbol at or near 'myFunc' 

注：如果我形容B，不含其设置为元组，我得到的结果B：{（）}。我给myFunc打错了吗？我无法弄清楚如何将B中的行传递给myFunc。

Answer 1

我想你是缺少生成关键字在foreach。

你可以尝试如下修改代码：

C = FOREACH B GENERATE myFunc.func(y);