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")
  • Last updated on