Ho questo codice nella Pig (vittoria, richiesta e risposta sono solo tabelle caricati direttamente dal file system):Pig, come fare riferimento a un campo dopo un join e un gruppo da
win_request = JOIN win BY bid_id, request BY bid_id;
win_request_response = JOIN win_request BY win.bid_id, response BY bid_id;
win_group = GROUP win_request_response BY (win.campaign_id);
win_count = FOREACH win_group GENERATE group, SUM(win.bid_price);
Fondamentalmente voglio sommare il bid_price dopo l'ingresso e il raggruppamento, ma ottengo un errore:
Could not infer the matching function for org.apache.pig.builtin.SUM as multiple or none of them fit. Please use an explicit cast.
mia ipotesi è che non mi riferisco correttamente win.bid_price
.