mode (DataFrameWriter)

Указывает поведение, когда данные или таблица уже существуют.

Синтаксис

mode(saveMode)

Параметры

Параметр Тип Описание
saveMode str Режим сохранения. Допустимые значения: 'append' (добавление к существующим данным), 'overwrite' (перезапись существующих данных) 'error' или 'errorifexists' (исключение, если данные существуют), и 'ignore' (автоматически пропускать, если данные существуют).

Возвраты

DataFrameWriter

Примеры

Напишите файл Parquet обратно с различными режимами и считывайте его обратно.

import tempfile
with tempfile.TemporaryDirectory(prefix="mode") as d:
    # Overwrite the path with a new Parquet file
    spark.createDataFrame(
        [{"age": 100, "name": "Alice"}]
    ).write.mode("overwrite").format("parquet").save(d)

    # Append another DataFrame into the Parquet file
    spark.createDataFrame(
        [{"age": 120, "name": "Sue"}]
    ).write.mode("append").format("parquet").save(d)

    # Read the Parquet file as a DataFrame.
    spark.read.parquet(d).show()
    # +---+-------------+
    # |age|         name|
    # +---+-------------+
    # |120| Sue          |
    # |100| Alice       |
    # +---+-------------+