Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Fügt den Inhalt der DataFrame Tabelle in die angegebene Tabelle ein. Erfordert, dass das Schema der DataFrame Tabelle mit dem Schema der Tabelle identisch ist.
Syntax
insertInto(tableName, overwrite=None)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
tableName |
str | Der Name der Zieltabelle. |
overwrite |
bool, optional | Wenn True, überschreibt vorhandene Daten. Standardmäßig deaktiviert. |
Rückkehr
Nichts
Hinweise
Im Gegensatz dazu DataFrameWriter.saveAsTableDataFrameWriter.insertInto werden Spaltennamen ignoriert und positionsbasierte Auflösung verwendet.
Beispiele
Fügen Sie Daten mithilfe der positionsbasierten Auflösung in eine Tabelle ein, wobei Spaltennamen ignoriert werden.
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")