sortBy

Mengurutkan output di setiap wadah menurut kolom yang diberikan pada sistem file.

Sintaksis

sortBy(col, *cols)

Parameter-parameternya

Parameter	Tipe	Deskripsi
col	str, tuple, atau daftar	Nama kolom, atau daftar nama.
*cols	str, opsional	Nama kolom tambahan. Harus kosong jika col adalah daftar.

Pengembalian Barang

DataFrameWriter

Examples

Tulis DataFrame ke dalam tabel yang diurutkan, dan baca kembali.

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")