Join-uri obișnuite
Ai primit două DataFrame-uri pe care trebuie să le combini într-unul singur, util pentru analiză. Prima sarcină este să combini DataFrame-urile în mod obișnuit și să vizualizezi planul de execuție.
DataFrame-urile flights_df și airports_df îți sunt disponibile.
Acest exercițiu face parte din cursul
Curățarea datelor cu PySpark
Instrucțiuni pentru exercițiu
- Creează un nou DataFrame
normal_dfprin join-ul dintreflights_dfșiairports_df. - Identifică tipul de join folosit în planul de interogare.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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.____()