zařadit

Funkce okna: Vrátí pořadí řádků v rámci oddílu okna.

Rozdíl mezi pořadím a dense_rank spočívá v tom, že dense_rank nezanechá žádné mezery v pořadí řazení, pokud existují vazby. To znamená, že kdybyste umístili soutěž pomocí dense_rank a měli tři osoby svázané na druhém místě, řekli byste, že všechny tři byly na druhém místě a že další osoba přišla ve třetí. Pořadí by mi dal pořadová čísla, takže osoba, která přišla na třetí místo (po vazbách), by se zaregistrovala jako pátá.

To je ekvivalentem funkce RANK v SQL.

Syntaxe

from pyspark.sql import functions as sf

sf.rank()

Parametry

Tato funkce nepřebírají žádné parametry.

Návraty

pyspark.sql.Column: sloupec pro výpočet pořadí.

Examples

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("drank", sf.rank().over(w)).show()

+-----+-----+
|value|drank|
+-----+-----+
|    1|    1|
|    1|    1|
|    2|    3|
|    3|    4|
|    3|    4|
|    4|    6|
+-----+-----+