下面是一个简单的例子，演示如何使用 COGROUP 操作符：
-- 载入两个数据集
A = LOAD 'input1.txt' USING PigStorage(',') AS (id:int, name:chararray);
B = LOAD 'input2.txt' USING PigStorage(',') AS (id:int, salary:float);
-- 使用 COGROUP 进行联合分组
C = COGROUP A BY id, B BY id;
-- 对每个联合组计算平均工资
D = FOREACH C GENERATE group AS id, AVG(B.salary) AS avg_salary;
-- 显示结果
DUMP D;
在上述例子中，COGROUP A BY id, B BY id; 将数据集 A 和 B 根据它们的 id 字段进行联合分组。然后，通过 FOREACH 和 GENERATE 对每个联合组进行聚合操作，计算平均工资。最后，使用 DUMP D; 显示结果。
在 COGROUP 操作中，group 是一个特殊的关键字，表示联合分组的字段值。与 GROUP 不同的是，COGROUP 可以同时处理多个数据集，并在结果中为每个数据集分配一个特殊的标签（这里是 A 和 B）。
需要注意的是，COGROUP 操作将返回一个元组，其中包含联合分组的字段值以及每个数据集中的组。这使得你可以对每个联合组执行各种操作，例如聚合、过滤等。
总的来说，COGROUP 操作符在 Apache Pig 中用于处理多个数据集的联合分组，提供了在这些数据集上执行复杂操作的便利性。
转载请注明出处：http://www.pingtaimeng.com/article/detail/11095/Apache Pig