モード（DataFrameWriter）

データまたはテーブルが既に存在する場合の動作を指定します。

構文

mode(saveMode)

パラメーター

パラメーター	Type	説明
saveMode	str	セーブモード。受け入れられる値は、 'append' （既存のデータに追加）、 'overwrite' （既存のデータを上書き）、 'error'または'errorifexists' （データが存在する場合は例外をスロー）、 'ignore' （データが存在する場合は黙ってスキップ）です。

パラメーター	Type	説明
saveMode	str	セーブモード。受け入れられる値は、 'append' （既存のデータに追加）、 'overwrite' （既存のデータを上書き）、 'error'または'errorifexists' （データが存在する場合は例外をスロー）、 'ignore' （データが存在する場合は黙ってスキップ）です。

戻り値

DataFrameWriter

例

Parquetファイルを様々なモードで書き戻し、それを読み込む。

Python

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       |
    # +---+-------------+