Pig群中的简单平均值？

mlmc2os5 于 2021-06-24 发布在 Pig

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

我有一个非常简单的2列数据，有一个双精度和一个字符：

user1 234.43
user1 432.23
user2 4321.213
etc.

我想按用户分组，然后计算他们双倍的平均值。怎样？我需要一个“团体”吗？我试着去学例2http://wiki.apache.org/pig/pigoverview ，但对我没用。

selfReportsAndDiscrepancies = FOREACH discrepancies1 GENERATE discrepancy,selfReportedText;
perDiscrepancy = GROUP selfReportsAndDiscrepancies BY selfReportedText;

allDiscrep = group perDiscrepancy all;

means = FOREACH allDiscrep GENERATE AVG(perDiscrepancy.discrepancy);

DUMP means;
DESCRIBE means;

给了我：

2013-04-02 17:54:06,611 [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1128: Cannot find field discrepancy in group:chararray,selfReportsAndDiscrepancies:bag{:tuple(discrepancy:double,selfReportedText:chararray)}

apache-pig

来源：https://stackoverflow.com/questions/15777076/simple-avg-in-pig-groups

1条答案

按热度按时间

mspsb9vt1#

我希望我对你的理解是正确的，你想要小组平均数的平均值：

VISITS = LOAD 'data' USING PigStorage(' ')  AS (user:chararray, number:double);
USER_VISITS = GROUP VISITS BY user;
USER_AVG = FOREACH USER_VISITS GENERATE group AS user, AVG(VISITS.number) AS average;
ALL_AVG = GROUP USER_AVG ALL;
OVERALL_AVG = FOREACH ALL_AVG GENERATE AVG(USER_AVG.average);
DUMP OVERALL_AVG;

结果：

(2327.2715)

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

我来回答

Pig群中的简单平均值？

1条答案

相关问题

热门标签

最新问答