cume_dist

Window işlevi: Bir pencere bölümü içindeki değerlerin toplu dağılımını, yani geçerli satırın altındaki satırların kesirini döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.cume_dist()

Parametreler

Bu işlev herhangi bir parametre almaz.

İade

pyspark.sql.Column: kümülatif dağılımı hesaplama sütunu.

Örnekler

from pyspark.sql import functions as sf
from pyspark.sql import Window
df = spark.createDataFrame([1, 2, 3, 3, 4], "int")
w = Window.orderBy("value")
df.withColumn("cd", sf.cume_dist().over(w)).show()

+-----+---+
|value| cd|
+-----+---+
|    1|0.2|
|    2|0.4|
|    3|0.8|
|    3|0.8|
|    4|1.0|
+-----+---+