0
假设我们有test_file
以下数据:如何拉平一组包内的元组
1, 3, 4
1, 5, 6
和下面的脚本:
r1 = load 'test_file' using PigStorage(',') as (a:int, b:int, c:int);
r2 = foreach r1 generate a, (b, c) as bc;
r2_group = group r2 by a;
r3 = foreach r2_group generate group as a, r2.bc as bc;
的r3
将如下所示:
(1, {((3, 4)), ((5,6))})
那么,我该如何修改上面的脚本来产生下面的东西?
(1, ((3,4), (5,6)))