输入：

jon,mario,2345
joe,minesweeper,234
peter,mario,112
lisa,minesweeper,900

Pig脚本：

game_data = LOAD 'game_data.csv'  USING  PigStorage(',') AS (player:chararray, game:chararray,  score:long);
game_data_grp_by_game = GROUP game_data BY game;
game_kpis = FOREACH game_data_grp_by_game {
 ord_game_data_by_score = ORDER game_data BY score DESC;
 max_score_record = LIMIT ord_game_data_by_score 1;
 GENERATE group AS game, FLATTEN(max_score_record.player) AS player_name, FLATTEN(max_score_record.score) AS score; 
};

输出：转储游戏\u KPI:

(mario,jon,2345)
(minesweeper,lisa,900)