Сводные строки в Pig

Question

У меня есть входные данные, как:

Abhinav,10K 
Abhinav,20K 
Abhinav,30K 
Nitin,15K 
Nitin,25K 
Mohit,50K 

мне нужен конечный результат, как:

(Abhinav,10K,20K,30K) 
(Nitin,15K,25K) 
(Mohit,50K) 

Я пришел до этого промежуточного пункта:

(Abhinav,{(10K),(20K),(30K)}) 
(Mohit,{(50K)}) 
(Nitin,{(15K),(25K)}) 

Кроме того, есть ли способ конвертировать эту промежуточную точку в окончательное решение.

Answer 1

Как-то я получил ответ, и это очень легко!

NameSal = LOAD '/home/asingh50/NameSalary.txt' USING PigStorage(',') AS(name:chararray,salary:chararray); 
NameSalGroup = GROUP NameSal by (name); 
NameSalResult = FOREACH NameSalGroup GENERATE group AS Name, BagToString(NameSal.salary, ',') as salary:chararray;