Joindre les vols avec leurs aéroports de destination
Vous avez été embauché comme ingénieur de données par une entreprise de voyages internationale. Votre première tâche consiste à aider l'entreprise à améliorer ses opérations en analysant des données sur les vols. Vous avez deux jeux de données dans votre espace de travail : l'un contient des détails sur les vols (flights) et l'autre des renseignements sur les aéroports de destination (airports), tous deux déjà disponibles dans votre espace de travail.
Votre objectif ? Combiner ces jeux de données pour créer un ensemble puissant qui associe chaque vol à son aéroport de destination.
Cette activité fait partie du cours
Introduction à PySpark
Instructions de l’exercice
- Examinez le DataFrame
airports. Relevez quelle colonne clé vous permettra de joindreairportsà la tableflights. - Joignez
flightsavec le DataFrameairportssur la colonne"dest". Enregistrez le résultat sousflights_with_airports. - Examinez de nouveau
flights_with_airports. Notez les nouvelles informations qui ont été ajoutées.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# 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.____