hadoop - 从Pig作业中提取值

Question

我正在处理以下格式的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 FLATTEN和 GENERATE，但是前三个字段仍然分组在一起。

Answer 1

假设r1关系包含以下内容

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

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

r2 = FOREACH r1 GENERATE FLATTEN($0) AS(a1,a2,a3),$1;
dump r2;