0

次の入力データテーブルがあります。

Product Price  Country
A       5       Italy
B       4       USA
C       12      France
A       5       Italy
B       7       Russia

2つのID(製品と国)で集計運用を行っています。コードは次のとおりです。

t3 = LOAD '/home/Desktop/3_table.data' USING PigStorage('\t') AS (product:chararray, price:int, country:chararray);

group_pr = GROUP t3 BY (product, country);

price_1 = FOREACH group_pr GENERATE CONCAT(group.product, group.country), SUM(t3.price);

STORE price_1 INTO 'sum_by_product_country' USING PigStorage('\t');

出力は次のとおりです。

AItaly  10
BUSA    4
BRussia 7
CFrance 12

問題は、入力データと出力をすべて一緒に含む完全なテーブルを取得する必要があるため、出力を期待すると、次のようになります。

A       5       Italy           AItaly      10
B       4       USA             BUSA        4
C       12      France          CFrance     12
B       7       Russia          BRussia     7

多分誰かが助けることができます、この出力を得る方法は?

4

0 に答える 0