假设我在apache-pig中有以下输入:
(123, ( (1, 2), (3, 4) ) )
(666, ( (8, 9), (10, 11), (3, 4) ) )
我想把这2行转换成以下7行:
(123, (1, 2) )
(123, (3, 4) )
(666, (8, 9) )
(666, (10, 11) )
(666, (3, 4) )
也就是说,这有点像"做与一个集团相反的事情"。这可能是猪拉丁语吗?
看看FLATTEN
。它可以满足你的需求。
然而,使用上面的符号,看起来元组列表就是一个元组。这应该是一个袋子,这样才能正常工作。
代替:
(123, ( (1, 2), (3, 4) ) )
(666, ( (8, 9), (10, 11), (3, 4) ) )
您应该将您的数据表示为:
(123, { (1, 2), (3, 4) } )
(666, { (8, 9), (10, 11), (3, 4) } )
然后,一旦是这种形式,你可以做:
O = FOREACH grouped GENERATE $0, FLATTEN($1);