PIG 中的 SUM 函数

Question

开始学习 Pig latin 脚本并坚持以下问题。我在同一个主题上经历了类似的问题，但没有任何运气！想求所有年龄字段的总和。

  DUMP X;
(22)(19)
grunt> DESCRIBE X;
X: {age: int}

我尝试了几个选项，例如：

Y = FOREACH ( group X all ) GENERATE SUM(X.age);

但是，低于异常。

 Invalid field projection. Projected field [age] does not exist in schema: group:chararray,X:bag{:tuple(age:int)}.

感谢您的时间和帮助。

Answer 1

我认为 Y 投影应该像你写的那样工作。这是相同的 mi 小示例代码，这对我来说很好。

 X = LOAD 'SO/sum_age.txt' USING PigStorage('\t') AS (age:int);
 DESCRIBE X;
 Y = FOREACH ( group X all ) GENERATE 
     SUM(X.age);
 DESCRIBE Y;
 DUMP Y;

所以你的问题看起来很奇怪。我使用了以下输入数据：

-bash-4.1$ cat sum_age.txt 
22
19

你能用我在这里插入的脚本尝试相同的数据吗？