次の入力データテーブルがあります。
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
多分誰かが助けることができます、この出力を得る方法は?