돼지를 사용하여 도시, 연도 및 임시 진입을 필터링합니까?

Question

기록 :

Pune,2007,31.5 
Pune,2007,30.5 
Pune,2008,34.5 
Blre,2009,13.0 
Blre,2009,10.5 

스크립트 내가 사용 :

grunt> A = LOAD '/home/cloudera/temp' using PigStorage(',') AS (city:chararray,year:int,temp:double); 
grunt> B = group A by city; 
grunt> C = FOREACH B GENERATE group, MAX(A.temp); 

출력 :

Pune, 34.5 
Blre, 13.0 

예상 출력 :이 연구를 달성 할 수있는 방법

Pune, 2007, 31.5 
Pune, 2008, 34.5 
Blre, 2009, 13.0 

esult, 미리 감사드립니다.

Answer 1

도시 및 연도 별 그룹화.

A = LOAD '/home/cloudera/temp' using PigStorage(',') AS (city:chararray,year:int,temp:double); 
B = group A by (city,year); 
C = FOREACH B GENERATE FLATTEN(group) AS (city,year), MAX(A.temp);