Bemærk
Adgang til denne side kræver godkendelse. Du kan prøve at logge på eller ændre mapper.
Adgang til denne side kræver godkendelse. Du kan prøve at ændre mapper.
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")