Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Trie la sortie dans chaque compartiment par les colonnes données sur le système de fichiers.
Syntaxe
sortBy(col, *cols)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
col |
str, tuple ou list | Nom d’une colonne ou liste de noms. |
*cols |
str, facultatif | Noms de colonnes supplémentaires. Doit être vide s’il col s’agit d’une liste. |
Retours
DataFrameWriter
Exemples
Écrivez un DataFrame dans une table triée et lisez-la.
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")