Kom igångKom igång gratis

Joina flyg med deras destinationsflygplatser

Du har blivit anlitad som dataingenjör på ett globalt reseföretag. Din första uppgift är att hjälpa företaget att förbättra sin verksamhet genom att analysera flygdata. Du har två datamängder i din arbetsyta: en med information om flyg (flights) och en med information om destinationsflygplatser (airports) – båda finns redan tillgängliga i din arbetsyta.

Målet? Kombinera dessa datamängder för att skapa en sammanslagen datamängd som kopplar varje flyg till dess destinationsflygplats.

Den här övningen är en del av kursen

Introduktion till PySpark

Visa kurs

Övningsinstruktioner

  • Undersök airports-DataFramen. Notera vilken nyckelkolumn du kan använda för att joina airports med tabellen flights.
  • Joina flights med airports-DataFramen på kolumnen "dest". Spara resultatet som flights_with_airports.
  • Undersök flights_with_airports igen. Notera den nya information som har lagts till.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

# 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.____
Redigera och kör kod