PIG에서 복수 레코드로 레코드 분할하기

Question

마지막 세 필드에 대해 여러 개의 입력을 생성하고 싶습니다. 하나의 레코드에서 하나의 레코드 당 하나의 세금 인스턴스를 만들고 싶습니까? 돼지에서 어떤 방법을 사용해야합니까?

입력 스키마

id  key adr   name  tax  tax1  tax2 

123456|1234|123 main st| jane doe| 123xxx | 124xxx | 125xxx 

그것은 돼지에 위의 입력에서 다음과 같은 출력을 얻을 수 있습니까?

123456|1234|123 main st| jane doe| 123xxx 

123456|1234|123 main st| jane doe| 124xxx 

123456|1234|123 main st| jane doe| 125xxx 

Answer 1

는()

A = LOAD 'data.txt' USING PigStorage(','); 
B = FOREACH A GENERATE $0,$1,$2,$3,FLATTEN(ToBag($4,$5,$6)); 
DUMP B;