Začněte nyníZačněte zdarma

Spojení letů s jejich cílovými letišti

Nastoupil/a jsi jako datový inženýr do globální cestovní společnosti. Tvým prvním úkolem je pomoci firmě zlepšit provoz analýzou dat o letech. V pracovním prostředí máš k dispozici dvě datové sady: jednu s podrobnostmi o letech (flights) a druhou s informacemi o cílových letištích (airports) — obě jsou už připravené.

Tvůj cíl? Propojit tyto datové sady a vytvořit výkonný dataset, který každý let spojí s jeho cílovým letištěm.

Toto cvičení je součástí kurzu

Introduction to PySpark

Zobrazit kurz

Pokyny k cvičení

  • Prohlédni si DataFrame airports. Zjisti, který klíčový sloupec ti umožní spojit airports s tabulkou flights.
  • Spoj flights s DataFrame airports přes sloupec "dest". Výsledek ulož jako flights_with_airports.
  • Prohlédni si flights_with_airports znovu. Všimni si nových informací, které přibyly.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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.____
Upravit a spustit kód