Une fonction de fenêtre calcule une valeur pour chaque ligne à partir d'un groupe de lignes liées, sans les réduire en une seule : rang, total cumulé, valeur précédente. Elle se définit avec un partitionnement (partitionBy), un tri (orderBy) et éventuellement un cadre de lignes.
Exemple
w = Window.partitionBy('client').orderBy('date')
df.withColumn('rang', F.row_number().over(w))