Проецирование сгруппированных кортежей в Pig

У меня есть набор кортежей формы (t,a,b), которые я хочу сгруппировать по b на рис. После группировки я хочу отфильтровать b из кортежей в каждой группе и создать пакет отфильтрованных кортежей для каждой группы.

В качестве примера предположим, что у нас есть (1,2,1) (2,0,1) (3,4,2) (4,1,2) (5,2,3)

Сценарий свиньи выдаст {(1,2),(2,0)} {(3,4),(4,1)} {(5,2)}

Вопрос в том, как мне получить этот результат? Я привык видеть примеры, когда операции агрегирования следуют за группой за операцией. Мне менее понятно, как фильтровать кортежи и возвращать их в сумку. Спасибо за твою помощь!

8
задан Chris 29 May 2012 в 23:39
поделиться