如何將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'));