insertInto

Inserta el contenido de en DataFrame la tabla especificada. Requiere que el esquema de DataFrame sea el mismo que el esquema de la tabla.

Sintaxis

insertInto(tableName, overwrite=None)

Parámetros

Parámetro	Tipo	Descripción
tableName	str	Nombre de la tabla de destino.
overwrite	bool, opcional	Si Truees , sobrescribe los datos existentes. Deshabilitado de forma predeterminada.

Devoluciones

Ninguno

Notas

A diferencia DataFrameWriter.saveAsTablede , DataFrameWriter.insertInto omite los nombres de columna y usa la resolución basada en posición.

Ejemplos

Inserte datos en una tabla mediante la resolución basada en la posición, ignorando los nombres de columna.

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