Zwykłe złączenia
Masz do dyspozycji dwa DataFrame, które należy połączyć w jeden przydatny zbiór danych. Twoim pierwszym zadaniem jest standardowe połączenie tych DataFrame oraz przejrzenie planu wykonania.
DataFrame flights_df i airports_df są już dostępne.
To ćwiczenie jest częścią kursu
Czyszczenie danych w PySpark
Instrukcje do ćwiczenia
- Utwórz nowy DataFrame
normal_df, łączącflights_dfzairports_df. - Określ, jakiego typu złączenia użyto w planie zapytania.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# 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.____()