为了得到像你开始那样的结果，我做了：

grunt> A = LOAD '../../../input/tuplesSample.txt' using PigStorage(' ') AS (grupo:chararray, charo:chararray);
grunt> DESCRIBE A;
A: {grupo: chararray,charo: chararray}
grunt> B = GROUP A by grupo;
grunt> DESCRIBE B;
B: {group: chararray,A: {(grupo: chararray,charo: chararray)}}
grunt> C = FOREACH B GENERATE $0 as grupo, $1.charo as charos;
grunt> DESCRIBE C;
C: {grupo: chararray,charos: {(charo: chararray)}}
grunt> DUMP C;
C: {grupo: chararray,charos: {(charo: chararray)}}
(g1,{(a1),(a2),(a3)})
(g2,{(b4),(b3),(b2),(b1)})
(g3,{(c4),(c5),(c6),(c2),(c1),(c3)})

我这么做是为了给你一个新的关系( E （见下文）包含单个袋子中的所有元素。

grunt> D = FOREACH C GENERATE FLATTEN($1) as charos;
grunt> DESCRIBE D;
D: {charos: chararray}

grunt> E = GROUP D ALL;
grunt> DESCRIBE E;
E: {group: chararray,D: {(charos: chararray)}}
grunt> DUMP E;
(all,{(c3),(c1),(c2),(c6),(c5),(c4),(b1),(b2),(b3),(b4),(a3),(a2),(a1)})

如果您想要我认为您想要的，您正在寻求创建一个新的关系，其中以前在分组包中的每个元组现在都是一个完整的记录。为此，请使用 FLATTEN 接线员，把袋子炸成多个记录。如果您可以假设包中的所有元组都具有相同的模式，那么您还可以 FLATTEN 将元组元素提升到完整字段的步骤：
如果 A 是分组的结果，并且

DESCRIBE A;
{(key:chararray, bag:{})}

你能做到的

B = FOREACH A GENERATE FLATTEN(bag) AS tuple;

然后要将元组转换为整行，请执行以下操作

C = FOREACH B GENERATE FLATTEN(tuple);

你可以阅读更多关于 FLATTEN 在这里。