Sur

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

Syntaxe

over(window)

Paramètres

Retours

Colonne

Exemples

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()

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