模式(DataFrameWriter)

指定當資料或資料表已存在時的行為。

語法

mode(saveMode)

參數

參數 類型 說明
saveMode str 存檔模式。 接受的值包括 'append' (附加於現有資料)、 'overwrite' (覆寫現有資料)、 'error''errorifexists' (若存在資料則拋出例外)、以及 'ignore' (若存在資料則靜默跳過)。

退貨

DataFrameWriter

Examples

用各種模式寫回 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       |
    # +---+-------------+