Как сделать «подведение итогов» на латинском языке?

Question

Я пытаюсь выполнить операцию суммирования со свиньями.

К примеру, у меня есть таблица с именем t3:

product price country 

A 5 Italy 

B 4 USA 

C 12 France 

A 5 Italy 

B 7 Russia 

мне нужно сделать операцию реферирования, используя 2 ключа: product и country.

1. я операцию конкатенации, используя product и country
2. Я должен рассчитать цену, суммируя значения цен только где CONCAT результат повторяет
3. Где CONCAT результат не повторяется, цена остается такой же, как в t3 таблица.

Ожидаемый выход может быть:

CONCAT Price_1 
AItaly 10 
BUSA 4 
CFrance 12 
BRussia 7 

В свинью я пишу следующий скрипт (код неправильно, а просто показать идею):

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



c1 = FOREACH t3 GENERATE CONCAT(product, country); 


c2 = FOREACH t3 GENERATE *, c1; 

product_1 = GROUP c2 BY c1; 
price_1 = FOREACH product_1 GENERATE group, SUM(product_1.price); 

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

Может быть кто-то может объяснить как достичь ожидаемого результата? Большое спасибо!

Answer 1

Если вы хотите рассчитать сумму платежа на продукт и в страну, вам не нужно использовать функцию concat. Просто группируйтесь по этим двум полям.

A = LOAD 's.txt' USING PigStorage('\t') AS (product:chararray, price:int, country:chararray); 
B = GROUP A BY (product, country); 
C = FOREACH B GENERATE CONCAT(group.product,group.country), SUM(A.price); 

На самом деле, конкат не нужен здесь, это только формат вывода, как ожидалось.

DUMP C 

(AItaly,10) 
(BUSA,4) 
(BRussia,7) 
(CFrance,12)