指定當資料或資料表已存在時的行為。
語法
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 |
# +---+-------------+