Note
Access to this page requires authorization. You can try signing in or changing directories.
Access to this page requires authorization. You can try changing directories.
Inserts the content of the DataFrame into the specified table. Requires that the schema of the DataFrame is the same as the schema of the table.
Syntax
insertInto(tableName, overwrite=None)
Parameters
| Parameter | Type | Description |
|---|---|---|
tableName |
str | The name of the target table. |
overwrite |
bool, optional | If True, overwrites existing data. Disabled by default. |
Returns
None
Notes
Unlike DataFrameWriter.saveAsTable, DataFrameWriter.insertInto ignores column names and uses position-based resolution.
Examples
Insert data into a table using position-based resolution, ignoring column names.
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")