メインコンテンツまでスキップ

モード(DataFrameWriter)

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

構文

mode(saveMode)

パラメーター

パラメーター

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 |
# +---+-------------+
このページの見出し