Pig Sắp xếp theo Query

Question

grunt> dump jn; 

(k1,k4,10) 
(k1,k5,15) 
(k2,k4,9) 
(k3,k4,16) 

grunt> jn = group jn by $1; 
grunt> dump jn; 


(k4,{(k1,k4,10),(k2,k4,9),(k3,k4,16)}) 
(k5,{(k1,k5,15)}) 

Bây giờ, từ đây tôi muốn đầu ra sau đây:

(k4,{(k3,k4,16),(k1,k4,10)}) 
(k5,{(k1,k5,15)}) 

Bascially, tôi muốn sắp xếp vào những con số: 10,9,16 và chọn top 2 cho mỗi hàng .
Tôi làm cách nào?

Answer 1

này tương tự như question này và bạn có thể sử dụng một Nested FOREACH, ví dụ .:

A = LOAD 'data'; 
jn = group A by $1; 
B = FOREACH jn { 
    sorted = ORDER A by $2 ASC; 
    lim = LIMIT sorted 2; 
    GENERATE lim; 
}; 
DUMP B;