kurtarmak

öğesinin DataFrame içeriğini bir veri kaynağına kaydeder. Veri kaynağı ve kümesi formattarafından options belirtilir. Belirtilmezse format , tarafından spark.sql.sources.default yapılandırılan varsayılan veri kaynağı kullanılır.

Sözdizimi

save(path=None, format=None, mode=None, partitionBy=None, **options)

Parametreler

Parametre	Türü	Açıklama
path	str, isteğe bağlı	Hadoop tarafından desteklenen bir dosya sistemindeki yol.
format	str, isteğe bağlı	Kaydetmek için kullanılan biçim.
mode	str, isteğe bağlı	Veriler zaten mevcut olduğunda davranış. Kabul edilen değerler , 'append', 'overwrite've 'ignore' veya 'error' (varsayılan) değerleridir'errorifexists'.
partitionBy	liste, isteğe bağlı	Bölümleme sütunlarının adları.
**options	Dict	Ek dize seçenekleri.

İadeler

Hiçbiri

Örnekler

Bir JSON dosyasına DataFrame yazın ve yeniden okuyun.

import tempfile
with tempfile.TemporaryDirectory(prefix="save") as d:
    spark.createDataFrame(
        [{"age": 100, "name": "Alice"}]
    ).write.mode("overwrite").format("json").save(d)

    spark.read.format('json').load(d).show()
    # +---+------------+
    # |age|        name|
    # +---+------------+
    # |100|Alice|
    # +---+------------+