与评分表进行连接
在视频练习中，您学习了如何在 PySpark 中通过将 film 和 ratings 表进行连接来创建一个新列，用于存储每位顾客的平均评分。
在本练习中，您将继续把 film 与 ratings 表结合起来，使用与视频练习相同的技巧来计算每部影片的平均评分。
包含影片信息的 PySpark DataFrame film_df 和包含评分的 PySpark DataFrame rating_df 已在您的工作区中提供。
本练习是课程的一部分
Data Engineering 入门
练习说明
- 按
film_id计算每部影片的平均评分，并将结果赋给ratings_per_film_df。 - 补全
.join()语句，在film_id列上进行连接。 - 显示结果 DataFrame 的前
5行。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Use groupBy and mean to aggregate the column
ratings_per_film_df = rating_df.____('____').____('____')
# Join the tables using the film_id column
film_df_with_ratings = film_df.join(
ratings_per_film_df,
film_df.film_id==____
)
# Show the 5 first results
print(film_df_with_ratings.____)