は、私は以下のフィールドを持つ海賊行為データセットから関係を持っている状態

Question

に基づいMIN、AVG、MAXの計算：

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

私はのSUMを計算するために、日付、国、映画、品質によってグループ化します値。しかし、私はまた、その日に利用可能な映画のすべてのトレントのtorrent_sizeのMIN、MAX、AVGを計算したいと思います。

これは私も日付無視の国で利用可能な映画の急流のMIN、MAX、AVGのサイズを行うするかどうかはわかりませんが、私はこれまで

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

を得たものです。

Answer 1

、映画を日付ごとに別の関係とグループを作成し、MIN、MAXを取得し、AVG

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; 

Answer 2

あなたは、以下のコマンドを確認することができます。

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; 

・ホープ、このことができますし。