Mam ten kod w Pig (Win, żądania i odpowiedzi są tylko tabele ładowane bezpośrednio z systemu plików):Świnia, jak odwołać się do pola po przyłączyć i grupa przez
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);
Zasadniczo chcę Podsumowując ten bid_price po przystąpieniu i grupowanie, ale pojawia się błąd:
Could not infer the matching function for org.apache.pig.builtin.SUM as multiple or none of them fit. Please use an explicit cast.
Domyślam się, że nie mówię o prawidłowej win.bid_price
.