Join normali
Ti sono stati forniti due DataFrame da combinare in un unico DataFrame utile. Il tuo primo compito è combinarli in modo standard e visualizzare il piano di esecuzione.
I DataFrame flights_df e airports_df sono a tua disposizione.
Questo esercizio fa parte del corso
Pulizia dei dati con PySpark
Istruzioni dell'esercizio
- Crea un nuovo DataFrame
normal_dffacendo il join diflights_dfconairports_df. - Determina quale tipo di join viene usato nel piano della query.
esercizio interattivo pratico
Prova questo esercizio completando questo 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.____()