sortWithinPartitions

Egy új DataFrame-et ad vissza, amely minden partíciót a megadott oszlop(ok) szerint rendez.

Szemantika

sortWithinPartitions(*cols: Union[int, str, Column, List[Union[int, str, Column]]], **kwargs: Any)

Paraméterek

Paraméter	Típus	Leírás
cols	int, str, list or Column( nem kötelező)	a rendezendő oszlop- vagy oszlopnevek vagy oszloprendek listája.
ascending	bool vagy list, optional, default True	logikai vagy logikai lista. Rendezés növekvő és csökkenő sorrendben. Több rendezési rendelés listáját adja meg. Ha egy lista meg van adva, a lista hosszának meg kell egyeznie a lista hosszával cols.

Visszatérítések

DataFrame: DataFrame partíciók szerint rendezve.

Jegyzetek

Az oszloprend 1-től kezdődik, amely eltér a 0-alapútól __getitem__. Ha egy oszloprend negatív, az csökkenő rendezést jelent.

Examples

from pyspark.sql import functions as sf
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.sortWithinPartitions("age", ascending=False)
# DataFrame[age: bigint, name: string]

df.coalesce(1).sortWithinPartitions(1).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  2|Alice|
# |  5|  Bob|
# +---+-----+

df.coalesce(1).sortWithinPartitions(-1).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  5|  Bob|
# |  2|Alice|
# +---+-----+