Объединение рейсов с аэропортами назначения

Вас наняли инженером по данным в крупную международную туристическую компанию. Ваша первая задача — помочь компании улучшить операционную эффективность с помощью анализа данных о рейсах. В вашем рабочем пространстве доступны два набора данных: один содержит сведения о рейсах (flights), другой — информацию об аэропортах назначения (airports).

Ваша цель — объединить эти наборы данных, чтобы создать единую таблицу, которая связывает каждый рейс с его аэропортом назначения.

Это упражнение является частью курса

Введение в PySpark

Посмотреть курс

Инструкции к упражнению

Изучите DataFrame airports. Определите, какой ключевой столбец позволит объединить airports с таблицей flights.
Объедините flights с DataFrame airports по столбцу "dest". Сохраните результат как flights_with_airports.
Изучите flights_with_airports ещё раз. Обратите внимание на новую информацию, которая появилась в таблице.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

# Examine the data
airports.____()

# .withColumnRenamed() renames the "faa" column to "dest"
airports = airports.withColumnRenamed("faa", "dest")

# Join the DataFrames
flights_with_airports = ____

# Examine the new DataFrame
flights_with_airports.____

Редактировать и запускать код