mode (DataFrameWriter)

指定数据或表已存在时的行为。

Syntax

mode(saveMode)

参数

参数 类型 Description
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       |
    # +---+-------------+