zadani 2
movies = load '/user/pn14_02/movies.csv' using PigStorage(',') as (isAdult : boolean, id : int, lang, releaseDate, runtime : float, title);
ratings = load '/user/pn14_02/ratings.csv' using PigStorage(',') as (userId : int, movieId :int, rating: float, timestamp : int);
engMovies = filter movies by lang == 'en';
otherMovies = filter movies by lang != 'en';
groupedRatings = group ratings by movieId;
averageRatingForMovie = foreach groupedRatings generate group as id, AVG(ratings.rating) as avgRating;
joinedEngMovies = join engMovies by id, averageRatingForMovie by id;
resultEngMovies = foreach joinedEngMovies generate engMovies::title, averageRatingForMovie::avgRating;
resultEngMovies = order resultEngMovies by averageRatingForMovie::avgRating desc;
resultEngMovies = limit resultEngMovies 1;
joinedOtherMovies = join otherMovies by id, averageRatingForMovie by id;
resultOtherMovies = foreach joinedOtherMovies generate otherMovies::title, averageRatingForMovie::avgRating;
resultOtherMovies = order resultOtherMovies by averageRatingForMovie::avgRating desc;
resultOtherMovies = limit resultOtherMovies 1;
res = union resultEngMovies, resultOtherMovies;
dump res;