2

double と chararray を持つ非常に単純な 2 列のデータがあります。

user1 234.43
user1 432.23
user2 4321.213
etc.

ユーザーごとにグループ化し、その double の平均を計算したいと考えています。どのように？「GROUP * ALL」は必要ですか? 例 2 http://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)}
4

1 に答える 1

2

グループ平均の平均が必要な場合は、正しく理解できたと思います。

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)
于 2013-04-03T07:33:51.913 に答える