insertInto

Vloží obsah tabulky DataFrame do zadané tabulky. Vyžaduje, aby schéma tabulky DataFrame bylo stejné jako schéma tabulky.

Syntaxe

insertInto(tableName, overwrite=None)

Parametry

Parameter	Typ	Description
tableName	str	Název cílové tabulky.
overwrite	bool, volitelné	Pokud Truepřepíše existující data. Ve výchozím nastavení vypnuto.

Návraty

None

Poznámky

Na rozdíl od DataFrameWriter.saveAsTablefunkce DataFrameWriter.insertInto ignoruje názvy sloupců a používá rozlišení na základě pozice.

Příklady

Do tabulky můžete vložit data pomocí rozlišení založeného na pozici a ignorovat názvy sloupců.

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")