Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Infogar innehållet i den DataFrame angivna tabellen. Kräver att schemat för DataFrame är samma som schemat för tabellen.
Syntax
insertInto(tableName, overwrite=None)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
tableName |
str | Namnet på måltabellen. |
overwrite |
bool, valfritt | Om Trueskriver du över befintliga data. Inaktiverat som standard. |
Retur
Ingen
Notes
Till skillnad från DataFrameWriter.saveAsTableignorerar DataFrameWriter.insertInto , kolumnnamn och använder positionsbaserad upplösning.
Exempel
Infoga data i en tabell med hjälp av positionsbaserad upplösning och ignorera kolumnnamn.
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")