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       |
    # +---+-------------+
  • Last updated on