Как передать результат функции CONCAT() в мой UDF в Pig?

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'));