豚を使用して毎年別の映画のリストを抽出

Question

私は豚に単純なコードを持っている、毎年映画の数を抽出したい、私は映画のファイルの内容をロードし、私はこのコードを入力：

groupingyear = group movies by year; 
vrar = foreach groupingyear generate movies.year, COUNT(movies.year); 

結果は正常です！しかし、私は（年、映画の数）の構造ではなく、この構造取得したい：（？なぜ年を何度も書かれている）を

Answer 1

あなたはフィールドMOVIE_NAMEを持つyears.Assumingをカウントしていますあなたの映画のデータセットで。

groupingyear = group movies by year; 
vrar = foreach groupingyear generate group, COUNT(movies.movie_name);