saveAsTable

Guarda o conteúdo do DataFrame como tabela especificada. Se a tabela já existir, o comportamento depende do mode parâmetro (o padrão é lançar uma exceção). Quando mode é 'overwrite', o esquema de não DataFrame precisa de corresponder ao esquema da tabela existente.

Sintaxe

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

Parâmetros

Parâmetro Tipo Descrição
name str O nome da tabela.
format STR, opcional O formato usado para guardar.
mode STR, opcional O comportamento quando os dados já existem. Os valores aceites são 'append', 'overwrite', 'error' ou 'errorifexists' (por defeito), e 'ignore'.
partitionBy STR ou lista, opcional Nomes das colunas de partição.
**options dicionário Opções adicionais de cordas.

Devoluções

Nenhum

Notes

Quando mode é 'append', se uma tabela já existe, utiliza-se o seu formato e opções. Ao contrário de , DataFrameWriter.insertInto usa nomes de DataFrameWriter.saveAsTablecolunas para encontrar as posições corretas das colunas.

Exemplos

Cria uma tabela a partir de um DataFrame e lê-a.

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