挿入先

DataFrameの内容を指定されたテーブルに挿入します。DataFrameのスキーマがテーブルのスキーマと同じである必要があります。

構文

insertInto(tableName, overwrite=None)

パラメーター

パラメーター	Type	説明
tableName	str	対象テーブルの名前。
overwrite	ブール値、オプション	Trueの場合、既存のデータを上書きします。デフォルトでは無効になっています。

パラメーター	Type	説明
tableName	str	対象テーブルの名前。
overwrite	ブール値、オプション	Trueの場合、既存のデータを上書きします。デフォルトでは無効になっています。

戻り値

なし

注意

DataFrameWriter.saveAsTableとは異なり、 DataFrameWriter.insertInto列名を無視し、位置ベースの解決を使用します。

例

列名を無視し、位置ベースの解決方法を使用してテーブルにデータを挿入します。

Python

spark.sql("DROP TABLE IF EXISTS tblA")
df = spark.createDataFrame([
    (100, "Alice"), (120, "Alice"), (140, "Bob")],
    schema=["age", "name"]
)
df.write.saveAsTable("tblA")

df.selectExpr("age AS col1", "name AS col2").write.insertInto("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |100|Alice|
# |120|Alice|
# |120|Alice|
# |140| Bob|
# |140| Bob|
# +---+------------+

spark.sql("DROP TABLE tblA")