hadoop - 将行值合并到列

Question

我有这样的数据

DUMP A;
(2013-11, a)
(2013-11, b)
(2013-11, c)
(2013-11, d)
(2013-12, e)

我想将具有相同键的行合并为这样(我想要的输出):

(2013-11, a, b, c, d)
(2013-12, e)

如何仅使用Pig Latin来实现此目的？

Answer 1

您正在寻找的是 GROUP 运算符。您可以像这样使用它:

-- A is your sample.

B = GROUP A BY $0 ;
DUMP B ;
-- (2013-11, {(a), (b), (c), (d)})
-- (2013-12, {(e)}

请注意，并不能保证袋子的字母顺序(或其他顺序)具有正确的数值。