一般連接(Normal joins)
你拿到兩個 DataFrame,要把它們合併成一個更有用的 DataFrame。第一步是先以一般方式合併這兩個 DataFrame,並查看執行計畫。
flights_df 與 airports_df 這兩個 DataFrame 已提供給你使用。
本練習屬於課程
使用 PySpark 清理資料
練習說明
- 使用
flights_df與airports_df進行連接,建立新的 DataFramenormal_df。 - 在查詢計畫中判斷實際使用的是哪一種連接類型。
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Join the flights_df and aiports_df DataFrames
normal_df = flights_df.____(____, \
flights_df["Destination Airport"] == airports_df["IATA"] )
# Show the query plan
normal_df.____()