Jointures normales
On vous a fourni deux DataFrames à combiner en un seul DataFrame utile. Votre première tâche consiste à les combiner de manière standard, puis à consulter le plan d'exécution.
Les DataFrames flights_df et airports_df sont à votre disposition.
Cette activité fait partie du cours
Nettoyer des données avec PySpark
Instructions de l’exercice
- Créez un nouveau DataFrame
normal_dfen joignantflights_dfavecairports_df. - Déterminez quel type de jointure est utilisé dans le plan de requête.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Join the flights_df and aiports_df DataFrames
normal_df = flights_df.____(____, \
flights_df["Destination Airport"] == airports_df["IATA"] )
# Show the query plan
normal_df.____()