Pular para o conteúdo principal

salvarComoTabela

Salva o conteúdo de DataFrame como a tabela especificada. Se a tabela já existir, o comportamento dependerá do parâmetro mode (default é lançar uma exceção). Quando mode é 'overwrite', o esquema de DataFrame não precisa 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 salvar.

mode

str, opcional

O comportamento quando os dados já existem. Os valores aceitos são 'append', 'overwrite', 'error' ou 'errorifexists' (default) e 'ignore'.

partitionBy

str ou lista, opcional

Nomes das colunas de particionamento.

**options

dicionário

Opções adicionais de strings.

Devoluções

Nenhuma

Notas

Quando mode é 'append', se uma tabela já existir, seu formato e opções serão usados. Ao contrário de DataFrameWriter.insertInto, DataFrameWriter.saveAsTable usa nomes de colunas para encontrar as posições de coluna corretas.

Exemplos

Crie uma tabela a partir de um DataFrame e leia-a de volta.

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