根据条件计算最小值、平均值、最大值

nzrxty8p 于 2021-06-21 发布在 Pig

关注(0)|答案(2)|浏览(440)

我与盗版数据集有以下字段的关系：

date, country_code, torrent_id, first_seen, torrent_size, quality, movie_id, value

我想按日期、国家、电影和质量进行分组，以计算值的总和。但我也要计算最小，最大，平均洪流大小的电影所有洪流当天可用。
这就是我目前得到的

A = FOREACH (GROUP data BY (date, country_code, movie_id, quality)) {
    GENERATE group, SUM(data.value) as total_piracy;
};

然而，我不知道如何做最小，最大，平均大小的影片洪流上的日期提供不顾国家以及。

apache-pig

来源：https://stackoverflow.com/questions/42075595/calculating-min-avg-max-based-on-condition

2条答案

按热度按时间

wgxvkvu91#

您可以检查以下命令：

A= LOAD '<locationOfDataSet>' USING PigStorage(',') 
AS (date:chararray, country_code:chararray, torrent_id:int, first_seen:chararray, torrent_size:int, quality:chararray, movie_id:int, value:int) ;
B=GROUP A BY (date,movie_id);
C=FOREACH B GENERATE group, MIN(A.torrent_size), MAX(A.torrent_size),AVG(A.torrent_size);
dump C;

希望这有帮助。

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

3bygqnnd2#

创建另一个关系并按日期、电影分组，然后获取最小值、最大值、平均值

B = GROUP data BY (date,movie);
C = FOREACH B GENERATE group, 
                       MIN(data.torrent_size) as min_ts,
                       MAX(data.torrent_size) as max_ts,
                       AVG(data.torrent_size) as avg_ts;

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

我来回答

根据条件计算最小值、平均值、最大值

2条答案

相关问题

热门标签

最新问答