Retour aux cas pratiques
Apache SparkAvancé

Implémentation d'une fenêtre analytique avec Window Functions

Scénario

Contexte Une équipe analytics souhaite calculer le rang des vendeurs par région ainsi que le chiffre d'affaires cumulé par mois. Le Problème Ces calculs nécessitent des fonctions analytiques que l'équipe tente d'implémenter avec des jointures multiples, générant un code illisible et peu performant. Contraintes Utiliser Window de pyspark.sql.window avec partitionBy() et orderBy(). Implémenter rank() pour le classement et sum() cumulatif avec rowsBetween(). Livrable attendu Un script PySpark utilisant les Window Functions pour calculer rang et cumul sans jointures redondantes.

Compétences ciblées

sparkwindow-functionsrankanalyticspyspark
    Implémentation d'une fenêtre analytique avec Window Functions — mise en situation Apache Spark | CodeDuel