如何使用apache豬將一個包變成多個包？

Question

我有兩組數據的文件象下面這樣：

1,abc,10,dss 
2,efgh,as 
1,abc,10,1234 
2,efgh,as 
1,abc,10,7899 
2,efgh,as 

記錄，從第1是一組和以＃開始2記錄是不同集合。所以兩者都有不同的結構。如何區分這兩組記錄？

Answer 1

這裏是一個辦法......

A = LOAD '/user/data/split.txt' as line:chararray; 
B = FOREACH A GENERATE Flatten(TOKENIZE(line,' ')) ; 
B1 = filter B by $0 matches '1.*'; 
B2 = filter B by $0 matches '2.*'; 
DUMP B1 
DUMP B2 
or 
SPLIT B INTO B1 IF ($0 matches '1.*'), B2 IF ($0 matches '2.*'); 

Answer 2

隨着輸入的新的更新版本，這裏是其它解決方案

A = LOAD '/user/data/split.txt' as line:chararray; 
B1 = filter A by $0 matches '1.*'; 
B2 = filter A by $0 matches '2.*'; 
or 
SPLIT A INTO B1 IF ($0 matches '1.*'), B2 IF ($0 matches '2.*');