開始使用免費開始

一般連接(Normal joins)

你拿到兩個 DataFrame,要把它們合併成一個更有用的 DataFrame。第一步是先以一般方式合併這兩個 DataFrame,並查看執行計畫。

flights_dfairports_df 這兩個 DataFrame 已提供給你使用。

本練習屬於課程

使用 PySpark 清理資料

檢視課程

練習說明

  • 使用 flights_dfairports_df 進行連接,建立新的 DataFrame normal_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.____()
編輯並執行程式碼