Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
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")