从 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 FLATTEN
和 GENERATE
,但前三个字段仍然组合在一起。
假设 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;
我正在处理 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
,但前三个字段仍然组合在一起。
假设 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;