2016-07-19 12 views
0

まず私は、データと私はこのような構造を有している例の結果についてははどのように豚のグループ袋に

A = LOAD './test.txt' USING PigStorage(' ') AS (id:int, time:int, value:float); 

B = GROUP A BY time; 

Iグループを持っています。

1001 {(1,1001,0.2),(3,1001,0.3),(2,1001,0.3),(4,1001,0.6)} 
1002 {(2,1002,0.5),(1,1002,0.3),(3,1002,0.1),(4,1002,0.6)} 
1003 {(4,1003,0.2),(1,1003,0.8),(2,1003,0.4),(3,1003,0.5)} 

しかし、私は

1001  {(1,1001,0.2),(2,1001,0.3),(3,1001,0.3),(4,1001,0.6)} 
1002  {(1,1002,0.3),(2,1002,0.5),(3,1002,0.1),(4,1002,0.6)} 
1003  {(1,1003,0.8),(2,1003,0.4),(3,1003,0.5),(4,1003,0.2)} 

答えて

0

使用NESTED FOREACH

C = FOREACH B { 
      sort_by_id = ORDER A BY id; 
      GENERATE group, sort_by_id ; 
       }; 
+0

たいが、私は$ 0 ASCによってソート= ORDERのAのようなものを見つけました、ありがとう;. –

関連する問題