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
