hadoop - Pigでグループを単一のタプルにフラット化する方法は?

Question

これから：

(1, {(1,2), (1,3), (1,4)} )
(2, {(2,5), (2,6), (2,7)} )

...どうすればこれを生成できるでしょうか?

((1,2),(1,3),(1,4))
((2,5),(2,6),(2,7))

...そして、これをどのように生成できますか?

(1, 2, 3, 4)
(2, 5, 6, 7)

1行の場合、私はその方法を知っています。問題は、多くの行を反復処理し、同時に内部グループを操作する必要がある場合です。

Answer 1

を手に入れるために ：

((1,2),(1,3),(1,4))
((2,5),(2,6),(2,7))

あなたはこれを行うことができます ：

r4 = foreach r3 {
    Tmp=foreach $1 generate (a,b);
    generate FLATTEN(BagToTuple(Tmp));
};