hadoop - Hadoop Pig技术按功能分组

Question

我有一个关系A包含

(zip-code).

我还有另一个关系B包含

(name:gender:zip-code)

(x:m:1234)

(y:f:1234)

(z:m:1245)

(s:f:1235).

我想按A将关系B中的数据分组

C = GROUP B BY A::zipcode;

预期输出:

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

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

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

Answer 1

我看不到需要关系A。如果目标是按关系B中已经存在的邮政编码字段进行分组，则下面的代码就足够了。

C = GROUP B BY zip_code;

DUMP C; -- Will have the expected output.