Обʼєднання рейсів із їхніми аеропортами призначення

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

Мета? Обʼєднати ці набори даних і створити зручний набір, який повʼязує кожен рейс із його аеропортом призначення.

Ця вправа є частиною курсу

Вступ до PySpark

Переглянути курс

Інструкції до вправи

Перегляньте датафрейм airports. Визначте, який ключовий стовпець дасть змогу приєднати airports до таблиці flights.
Обʼєднайте flights із датафреймом 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.____

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