1

我正在使用 XMLLoader 在我的猪拉丁脚本中加载 XML。然后用我的 UDF 解析它。问题是我想将输入文件名合并到我的 UDF 中。

就像是

文件名 = (String)input.get(1);

这是我的猪拉丁代码供参考

REGISTER contrib/piggybank/java/piggybank.jar;
REGISTER TallyUDF.jar;
log = LOAD '/home/HadoopNaman1/pig/trunk/CompFetXML.xml' using  org.apache.pig.piggybank.storage..XMLLoader('ENVELOPE') as xml_record;
N = FOREACH log GENERATE FLATTEN(TallyUDF.ParseCompFet(xml_record)) as (key:CHARARRAY,value1:CHARARRAY,value2:CHARARRAY);
M = FILTER N by key is not null;
DUMP M;

我想我必须编辑 XMLLoader.java 代码。但是,我想不出该怎么做。

4

0 回答 0