以下のようなファイル「error_data.txt」があります。
10474 3.0 2013-05-01 7
10474 94.0 2013-05-01 3
10538 72.0 2013-05-01 15
11001 95.0 2013-05-01 248
13113 78.0 2013-05-01 18
13116 53.0 2013-05-01 4
13116 95.0 2013-05-01 1
13122 89.0 2013-05-01 2
10001 56.0 2013-05-02 7
10413 61.0 2013-05-02 6
.........
.........
これは私が今まで持っているもので、正常に動作します:
error_data = LOAD 'error_data.txt' AS (ppapi_error_code:int, api_version:chararray, day:chararray, count:long);
filtered_data = FILTER error_data BY api_version=='61.0';
grouped_data = GROUP filtered_data BY day;
grouped_count = FOREACH grouped_data GENERATE group AS day, SUM(filtered_data.count) AS error_count;
STORE grouped_count INTO 'out_1';
ここでやりたいことは、平均より大きいgrouped_count
値を持つ値をフィルタリングすることです。error_count
次のように平均を取得しました。
grouped_count_bag = GROUP grouped_count ALL;
average = FOREACH grouped_count_bag GENERATE AVG(grouped_count.error_count);
するとDUMP
、タプルの値を として取得します(578.9444444444445)
。次の値でフィルタリングできるようになりました
filtered_grouped_count = FILTER grouped_count BY (error_count>578.9444444444445);
しかし、私はそれをしたい
filtered_grouped_count = FILTER grouped_count BY (error_count>average);
これは許可されていないようです。どんな援助でも大歓迎です。