Обычные соединения
Вам предоставлены два DataFrame, которые нужно объединить в один полезный DataFrame. Ваша первая задача — выполнить обычное соединение DataFrame и просмотреть план выполнения.
DataFrame flights_df и airports_df уже доступны.
Это упражнение является частью курса
Очистка данных с помощью PySpark
Инструкции к упражнению
- Создайте новый DataFrame
normal_df, соединивflights_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.____()