Сбор данных по идентификатору в улье

Question

У меня есть таблица с строками в следующем формате

user | purchase | time_of_purchase|quantity 

Образец

1234 | Bread | Jul 7 20:48| 1 
1234 | Shaving Cream | July 10 14:20 | 2 
5678 | Milk | July 7 3:48 | 1 
5678 | Bread | July 7 3:49 | 2 
5678 | Bread | July 7 15:30 | 1 

Я хочу создать историю покупок пользователя в следующем формате

1234 | {[Bread , Jul 7 20:48,1] ,[ Shaving Cream , July 10 14:20, 2 ]} 
5678 | {[Milk, July 7 3:48 , 1 ] , [Bread , July 7 3:49 , 2], [Bread , July 7 15:30 , 1]} 

Возможно ли это сделать в сценарии улья или свиньи? Я попробовал collect_list, но это не позволяет упорядочивать столбцы, чтобы объединиться. Также попробовал кирпичный сбор, но он ведет себя как collect_set, и я теряю часть информации.

Answer 1

PIG Script

File = LOAD 'file.txt' using PigStorage(',') as (user:int, Purchase:chararray, timeofpurchase:chararray, quantity:int); 

GRP_USER = GROUP File by user; 
DUMP GRP_USER; 

вы можете сослаться немного примеров на http://ybhavesh.blogspot.com/

Надеюсь, что это помогает