plus de

Appliquer une spécification de fenêtre à la colonne.

Syntaxe

Python

over(window)

parameter

parameter	Type	Description
window	WindowSpec	Spécification de fenêtre

parameter	Type	Description
window	WindowSpec	Spécification de fenêtre

Renvoie

Colonne

Exemples

Python

from pyspark.sql import Window
from pyspark.sql.functions import rank, min, desc
window = (
    Window.partitionBy("name")
    .orderBy("age")
    .rowsBetween(Window.unboundedPreceding, Window.currentRow)
)
df = spark.createDataFrame(
     [(2, "Alice"), (5, "Bob")], ["age", "name"])
df.withColumn(
     "rank", rank().over(window)
).withColumn(
     "min", min('age').over(window)
).sort(desc("age")).show()

Output

# +---+-----+----+---+
# |age| name|rank|min|
# +---+-----+----+---+
# |  5|  Bob|   1|  5|
# |  2|Alice|   1|  2|
# +---+-----+----+---+