将航班与其目的地机场进行连接
您被一家全球旅行公司的数据工程师团队录用。您的第一项任务是通过分析航班数据来改进公司的运营。您的工作区中已有两个数据集：一个包含航班详情（flights），另一个包含目的地机场信息（airports），两者都已就绪可用。
您的目标？将这两个数据集合并，创建一个能将每个航班与其目的地机场关联起来的强大数据集。
本练习是课程的一部分
PySpark 入门
练习说明
- 查看
airportsDataFrame。确定可以将airports与flights表连接的键列。 - 在
"dest"列上将flights与airportsDataFrame 进行连接。将结果保存为flights_with_airports。 - 再次查看
flights_with_airports。留意新增的信息。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Examine the data
airports.____()
# .withColumnRenamed() renames the "faa" column to "dest"
airports = airports.withColumnRenamed("faa", "dest")
# Join the DataFrames
flights_with_airports = ____
# Examine the new DataFrame
flights_with_airports.____