hadoop - 如何将CONCAT()函数的结果传递给Pig中的UDF？

Question

我想将CONCAT()的结果传递给Pig中的用户定义函数。当前，我有一个带有下一行的脚本，但是运行该脚本时出现错误。

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

pig 有可能吗？

如果没有，是否可以将两个参数传递给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'));