Běžné joiny
Máš k dispozici dva DataFramy, které je potřeba sloučit do jednoho použitelného DataFrame. Tvým prvním úkolem je spojit tyto DataFramy běžným způsobem a prohlédnout si plán vykonání.
DataFramy flights_df a airports_df jsou připravené k použití.
Toto cvičení je součástí kurzu
Cleaning Data with PySpark
Pokyny k cvičení
- Vytvoř nový DataFrame
normal_dfspojenímflights_dfsairports_df. - Zjisti, jaký typ joinu se používá v plánu dotazu.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# 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.____()