pig Nested FOREACH

입력데이터가

time, name, id 일때

ID로 GROUPING을 하고

그룹핑된 갑들에 대해 time순으로 정렬하기 위해 아래와 같이 nested foreach를 사용한다.

A = FOREACH fields GENERATE time, name, id

B = GROUP A BY (id);

C = FOREACH B {

  sorted = ORDER A by time;

  GENERATE sorted;

};

STORE C INTO '/user/hadoop/jchern/test';