Hadoop猪技术按功能分组

Question

我有一个关系 A 包含

(zip-code).

我有另一个关系 B 包含

(name:gender:zip-code)

(x:m:1234)

(y:f:1234)

(z:m:1245)

(s:f:1235).

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

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.