使用豬提取每年不同電影的列表使用豬

Question

我有一個簡單的代碼豬，我想提取每年的電影數量，我加載了電影中的文件內容，我輸入此代碼：

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

結果很好！但我想要得到的（年，電影的數量）結構，而不是這樣的結構：（？爲什麼這些年來被多次寫入）

Answer 1

您計數years.Assuming你有一個字段MOVIE_NAME在您的電影數據集中。

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