Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Ordina l'output in ogni bucket in base alle colonne specificate nel file system.
Sintassi
sortBy(col, *cols)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
col |
str, tuple o list | Nome di colonna o elenco di nomi. |
*cols |
str, facoltativo | Nomi di colonna aggiuntivi. Deve essere vuoto se col è un elenco. |
Restituzioni
DataFrameWriter
Examples
Scrivere un dataframe in una tabella ordinata in bucket e leggerlo di nuovo.
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")