Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
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")