连接 DataFrame
接下来的两个章节中,您将基于我们一直使用的航班数据构建一个模型,用来预测航班是否会延误。该模型还会包含执飞航线的飞机信息,所以第一步需要把两张表连接起来:flights 和 planes!
本练习是课程的一部分
PySpark 基础
练习说明
- 首先,将
planes的year列重命名为plane_year,以避免重复的列名。 - 使用
tailnum列作为键,将flights表与planes进行连接,创建一个名为model_data的新 DataFrame。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Rename year column
planes = planes.withColumnRenamed(____)
# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")