Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
Egy új DataFrame-et ad vissza a megadott oszlop(ok) szerint rendezve.
Szemantika
sort(*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 vagy 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: Rendezett adatkeret.
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.sort(sf.asc("age")).show()
# +---+-----+
# |age| name|
# +---+-----+
# | 2|Alice|
# | 5| Bob|
# +---+-----+
df.sort(df.age.desc()).show()
# +---+-----+
# |age| name|
# +---+-----+
# | 5| Bob|
# | 2|Alice|
# +---+-----+
df.sort("age", ascending=False).show()
# +---+-----+
# |age| name|
# +---+-----+
# | 5| Bob|
# | 2|Alice|
# +---+-----+
df = spark.createDataFrame([
(2, "Alice"), (2, "Bob"), (5, "Bob")], schema=["age", "name"])
df.orderBy(sf.desc("age"), "name").show()
# +---+-----+
# |age| name|
# +---+-----+
# | 5| Bob|
# | 2|Alice|
# | 2| Bob|
# +---+-----+