在Pig中合并元组

Question

我有两组元组，我想通过第一个元素内联它们并将其他部分合并到一个元组中，想知道如何在Pig on Hadoop中实现这个？

输入二元组套，

1,(1,2) 
2,(2,3) 

1,(b,c,b,c) 
2,(c,d,c,d) 

预计输出，

1,(1,2,b,c,b,c) 
2,(2,3,c,d,c,d) 

在此先感谢， 林

Answer 1

一个想法值得考虑......

输入：

数据A：

1 (1,2) 
2 (2,3) 

数据B：

1 (b,c,b,c) 
2 (c,d,c,d) 

猪脚本：

A = LOAD 'dataA' USING PigStorage('\t') AS (aid:long, atuple : tuple(af1:long, af2:long)); 
B = LOAD 'dataB' USING PigStorage('\t') AS (bid:long, btuple : tuple(bf1:chararray, bf2:chararray, bf3:chararray, bf4:chararray)); 
C = JOIN A BY aid, B BY bid; 
D = FOREACH C GENERATE aid AS id, FLATTEN(atuple) AS (af1:long, af2:long) , FLATTEN(btuple) AS (bf1:chararray, bf2:chararray, bf3:chararray, bf4:chararray); 
E = FOREACH D GENERATE id, (af1..bf4); 
DUMP E; 

输出：d UMP E：

(1,(1,2,b,c,b,c)) 
(2,(2,3,c,d,c,d))