Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
Seřadí výstup v každém kontejneru podle zadaných sloupců v systému souborů.
Syntaxe
sortBy(col, *cols)
Parametry
| Parameter | Typ | Description |
|---|---|---|
col |
str, řazená kolekce členů nebo seznam | Název sloupce nebo seznam názvů |
*cols |
str, volitelné | Další názvy sloupců Pokud je seznam prázdný, musí být prázdný col . |
Návraty
DataFrameWriter
Příklady
Zapište datový rámec do seřazené tabulky a přečtěte si ho zpátky.
spark.sql("DROP TABLE IF EXISTS sorted_bucketed_table")
spark.createDataFrame([
(100, "Alice"), (120, "Alice"), (140, "Bob")],
schema=["age", "name"]
).write.bucketBy(1, "name").sortBy("age").mode(
"overwrite").saveAsTable("sorted_bucketed_table")
spark.read.table("sorted_bucketed_table").sort("age").show()
# +---+------------+
# |age| name|
# +---+------------+
# |100|Alice|
# |120|Alice|
# |140| Bob|
# +---+------------+
spark.sql("DROP TABLE sorted_bucketed_table")