Retour aux cas pratiques
Apache SparkFondamental

Utilisation de SQL sur un DataFrame via createOrReplaceTempView

Scénario

Contexte Une équipe habituée au SQL souhaite interroger un DataFrame Spark avec des requêtes SQL standard. Le Problème L'équipe ne maîtrise pas l'API DataFrame et préfère écrire des requêtes SQL pour les transformations. Contraintes Enregistrer le DataFrame comme vue temporaire avec createOrReplaceTempView(). Exécuter une requête SQL via spark.sql() pour calculer le chiffre d'affaires total par mois. Livrable attendu Un script PySpark démontrant l'utilisation de Spark SQL sur un DataFrame enregistré comme vue temporaire.

Compétences ciblées

sparksparksqltempviewsqlpyspark
    Utilisation de SQL sur un DataFrame via createOrReplaceTempView — mise en situation Apache Spark | CodeDuel