diff --git a/basic_re.py b/basic_re.py index fccca8e..5ab0bde 100644 --- a/basic_re.py +++ b/basic_re.py @@ -24,8 +24,7 @@ if __name__ == "__main__": movieIDsWithAvgRatingsRDD = movieIDsWithRatingsRDD.map(lambda rec: getCountsAndAverages(rec)) print('movieIDsWithAvgRatingsRDD1: %s\n' % movieIDsWithAvgRatingsRDD.take(3)) - movieNameWithAvgRatingsRDD = (moviesRDD.join(movieIDsWithAvgRatingsRDD) - .map(lambda movie: (movie[1][1][1], movie[1][0], movie[1][1][0]))) + movieNameWithAvgRatingsRDD = (moviesRDD.join(movieIDsWithAvgRatingsRDD).map(lambda movie: (movie[1][1][1], movie[1][0], movie[1][1][0]))) print('movieNameWithAvgRatingsRDD2: %s\n' % movieNameWithAvgRatingsRDD.take(3)) movieLimitedAndSortedByRatingRDD = (movieNameWithAvgRatingsRDD