如何将CONCAT（）函数的结果传递给Pig中的UDF？

Question

我想将一个CONCAT（）的结果传递给我在Pig中的用户定义函数。目前，我有一段脚本，但是脚本给我一个错误，当我运行它时。

B = FOREACH A GENERATE myjar.MyUDF(CONCAT(r1,r2)); 

这对猪有可能吗？

如果没有，有没有办法将两个参数传递给Pig UDF？

Answer 1

在Pig中，您可以将多个参数传递给UDF。

你可以像这样通过。

A = LOAD 'file.txt' USING PigStorage(',') AS (id:int,f_name:chararray,l_name:chararray); 

B = FOREACH A Generate id,name,MYUDF(CONCAT(f_name,l_name),lname,f_name,'hi'); 

还记得你可以在一个UDF的输出传递到另一个UDF

C = FOREACH B Generate UDF1(UDF2('hi'));