Hadoop pig technology group by function

manpreet Best Answer 2 years ago

i have a relation A contains

(zip-code).

i have another relation B contains

(name:gender:zip-code)

(x:m:1234)

(y:f:1234)

(z:m:1245)

(s:f:1235).

i want to group the data in relation B by A

C = GROUP B BY A::zipcode;

expected output:

(1234,{(y,f,1234),(x,m,1234)})

(1235,{(s,f,1235)})

(1245,{(z,m,1245)})

manpreet 2 years ago

I don't see the need of relation A. If objective is to group by zip code field which is already there in relation B then the below code is suffice.

C = GROUP B BY zip_code;

DUMP C; -- Will have the expected output