From a7039966c4fa8db195eb812df0aaa77ddc196f70 Mon Sep 17 00:00:00 2001 From: fly6516 Date: Tue, 22 Apr 2025 14:07:01 +0800 Subject: [PATCH] =?UTF-8?q?style(basic=5Fre.py):=20=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=A0=BC=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除多余的空行 - 将长行代码进行适当折行，提高可读性 --- basic_re.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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