1

以下のようなファイル「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);

これは許可されていないようです。どんな援助でも大歓迎です。

4

1 に答える 1