Compartilhar via

saveAsTable

Salva o conteúdo da DataFrame tabela especificada. Se a tabela já existir, o comportamento dependerá do parâmetro (o mode padrão é lançar uma exceção). Quando mode é 'overwrite', o esquema do DataFrame não precisa corresponder ao esquema de 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' (padrão) e 'ignore'.
partitionBy str ou list, opcional Nomes de colunas de particionamento.
**options dicionário Opções de cadeia de caracteres adicionais.

Devoluções

Nenhum

Observações

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

Exemplos

Crie uma tabela de um DataFrame e leia-a novamente.

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