Vanliga joins
Du har fått två DataFrames som ska kombineras till en enda användbar DataFrame. Din första uppgift är att kombinera DataFrames på vanligt sätt och sedan granska exekveringsplanen.
DataFrames flights_df och airports_df finns tillgängliga.
Den här övningen är en del av kursen
Datarensning med PySpark
Övningsinstruktioner
- Skapa en ny DataFrame
normal_dfgenom att koppla ihopflights_dfmedairports_df. - Avgör vilken typ av join som används i frågeplanens utdata.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# 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.____()