Normal joins
You've been given two DataFrames to combine into a single useful DataFrame. Your first task is to combine the DataFrames normally and view the execution plan.
The DataFrames flights_df and airports_df are available to you.
Questo esercizio fa parte del corso
Cleaning Data with PySpark
Istruzioni dell'esercizio
- Create a new DataFrame
normal_dfby joiningflights_dfwithairports_df. - Determine which type of join is used in the query plan.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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.____()