Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Hiermee voegt u de inhoud van de DataFrame opgegeven tabel in. Vereist dat het schema van de DataFrame tabel hetzelfde is als het schema van de tabel.
Syntaxis
insertInto(tableName, overwrite=None)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
tableName |
str | De naam van de doeltabel. |
overwrite |
bool, optioneel | Als True, worden bestaande gegevens overschreven. Standaard uitgeschakeld. |
Retouren
Geen
Aantekeningen
In tegenstelling tot DataFrameWriter.saveAsTable: DataFrameWriter.insertInto negeert kolomnamen en gebruikt op positie gebaseerde resolutie.
Examples
Voeg gegevens in een tabel in met behulp van een op positie gebaseerde resolutie, waarbij kolomnamen worden genegeerd.
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")