hadoop - 没有在 pig 中使用 SUM() 获得计算值

Question

我的命令如下:

Z = LOAD '/..file_path' USING PigStorage(',') AS (name:CHARARRAY,gpa:int,salary:int);
y = GROUP Z BY gpa;
R = FOREACH y GENERATE SUM(Z.salary);

我正在获取

的输出

DUMP R;

作为:

{all,()};

请指导我。TIA。

Answer 1

您需要使用 GROUP ALL 而不是 GROUP BY 来获取 SUM .

Z = LOAD '/..file_path' USING PigStorage(',') AS (name:CHARARRAY,gpa:int,salary:int);
y = GROUP Z ALL;
R = FOREACH y GENERATE SUM(Z.salary);
DUMP R;