如何使用xmloader将文件名合并到pig拉丁语脚本中?

nwo49xxi  于 2021-06-03  发布在  Hadoop
关注(0)|答案(0)|浏览(254)

我使用xmloader在pig拉丁语脚本中加载xml,然后用udf解析它。问题是我想将输入文件名合并到我的udf中。
像这样的
文件名=(字符串)input.get(1);
这是我的Pig拉丁代码供参考

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;

我想我必须编辑xmloader.java代码,但是我不知道该怎么做。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题