sortBy

Her demetteki çıkışı dosya sistemindeki belirli sütunlara göre sıralar.

Sözdizimi

sortBy(col, *cols)

Parametreler

Parametre Türü Açıklama
col str, tanımlama grubu veya liste Sütun adı veya ad listesi.
*cols str, isteğe bağlı Ek sütun adları. Listeyse col boş olmalıdır.

İadeler

DataFrameWriter

Örnekler

Sıralanmış demetli bir tabloya DataFrame yazın ve yeniden okuyun.

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