豚は、どのようにした後、フィールドを参照するには参加して、グループIは、豚にこのコードを持っている

Question

によって（勝利、リクエストとレスポンスがちょうどテーブルがファイルシステムから直接ロードされている）：

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); 

は基本的に私がしたいです入社してグループ化した後bid_priceを合計し、私はエラーを取得：

Could not infer the matching function for org.apache.pig.builtin.SUM as multiple or none of them fit. Please use an explicit cast. 

私の推測では、私はwin.bid_priceに正しく言及していないよということです。

Answer 1

複数の結合を実行する場合は、フィールドに固有の識別子（bid_idなど）を使用することをおすすめします。また、disambiguation operator '::'を使用することもできますが、かなり汚くなる可能性があります。

wins = LOAD '/user/hadoop/rtb/wins' USING PigStorage(',') AS (f1_w:int, f2_w:int, f3_w:chararray); 
reqs = LOAD '/user/hadoop/rtb/reqs' USING PigStorage(',') AS (f1_r:int, f2_r:int, f3_r:chararray); 
resps = LOAD '/user/hadoop/rtb/resps' USING PigStorage(',') AS (f1_rp:int, f2_rp:int, f3_rp:chararray); 

wins_reqs = JOIN wins BY f1_w, reqs BY f1_r; 
wins_reqs_reps = JOIN wins_reqs BY f1_r, resps BY f1_rp; 

win_group = GROUP wins_reqs_reps BY (f3_w); 

win_sum = FOREACH win_group GENERATE group, SUM(wins_reqs_reps.f2_w);