apache pig中的sum函数

szqfcxe2 于 2021-06-21 发布在 Pig

关注(0)|答案(1)|浏览(411)

开始学习Pig拉丁脚本和坚持在下面的问题。在同一个主题上，我也遇到过类似的问题，但我一点运气都没有！要查找所有年龄字段的总和。

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)}.

谢谢你的时间和帮助。

apache-pig apache-pig-grunt

来源：https://stackoverflow.com/questions/38019575/sum-function-in-pig

1条答案

按热度按时间

pkmbmrz71#

我认为y投影应该像你写的那样工作。这是我的小例子代码相同的，这只是工作的罚款为我。

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

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

赞(0）回复(0）举报 2021-06-21

我来回答

apache pig中的sum函数

1条答案

相关问题

热门标签

最新问答