classificação percentual

Função de janela: retorna a classificação relativa (ou seja, percentil) de linhas dentro de uma partição de janela.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.percent_rank()

Parâmetros

Esta função não recebe nenhum parâmetro.

Devoluções

pyspark.sql.Column: a coluna para calcular a classificação relativa.

Exemplos

Python

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

Output

+-----+---+
|value| pr|
+-----+---+
|    1|0.0|
|    1|0.0|
|    2|0.4|
|    3|0.6|
|    3|0.6|
|    4|1.0|
+-----+---+