Звичайні з'єднання
Вам надали два датафрейми, які потрібно об'єднати в один корисний датафрейм. Ваше перше завдання — звичайно об'єднати датафрейми та переглянути план виконання.
Датафрейми flights_df і airports_df доступні для вас.
Ця вправа є частиною курсу
Очищення даних у PySpark
Інструкції до вправи
- Створіть новий датафрейм
normal_df, виконавшиjoinflights_dfзairports_df. - Визначте, який тип з'єднання використано в плані запиту.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# 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.____()