从 Pig 作业中提取值

Extracting values from Pig job

我正在处理 Pig 作业的输出,格式如下:

((a,b,c),2014-12-27)
((a,b,c1),2014-12-27)

我想要这个结果:

(a,b,c,2014-12-27)
(a,b,c1,2014-12-27)

我试过使用 GENERATE FLATTENGENERATE,但前三个字段仍然组合在一起。

假设 r1 关系包含以下

((a,b,c),2014-12-27)
((a,b,c1),2014-12-27)

我们可以使用下面的语句来实现扁平化

r2 = FOREACH r1 GENERATE FLATTEN([=11=]) AS(a1,a2,a3),;
dump r2;