style(basic_re.py): 优化代码格式

- 删除多余的空行
- 将长行代码进行适当折行,提高可读性
This commit is contained in:
fly6516 2025-04-22 14:07:01 +08:00
parent cf26e01935
commit a7039966c4

View File

@ -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