saveAsTable

Guarda el contenido de como DataFrame la tabla especificada. Si la tabla ya existe, el comportamiento depende del mode parámetro (el valor predeterminado es iniciar una excepción). Cuando mode es 'overwrite', el esquema de no necesita coincidir con el esquema de DataFrame tabla existente.

Sintaxis

saveAsTable(name, format=None, mode=None, partitionBy=None, **options)

Parámetros

Parámetro	Tipo	Descripción
name	str	El nombre de la tabla.
format	str, opcional	Formato que se usa para guardar.
mode	str, opcional	Comportamiento cuando ya existen datos. Los valores aceptados son 'append', 'overwrite''error'o 'errorifexists' (valor predeterminado) y 'ignore'.
partitionBy	str o list, opcional	Nombres de columnas de creación de particiones.
**options	diccionario	Opciones de cadena adicionales.

Devoluciones

Ninguno

Notas

Cuando mode es 'append', si ya existe una tabla, se usan su formato y opciones. A diferencia de DataFrameWriter.insertInto, DataFrameWriter.saveAsTable usa nombres de columna para buscar las posiciones de columna correctas.

Ejemplos

Cree una tabla a partir de un dataframe y vuelva a leerla.

spark.sql("DROP TABLE IF EXISTS tblA")
spark.createDataFrame([
    (100, "Alice"), (120, "Bob"), (140, "Tom")],
    schema=["age", "name"]
).write.saveAsTable("tblA")

spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |120|Bob|
# |140| Tom|
# +---+------------+

spark.sql("DROP TABLE tblA")