inserir em

Insere o conteúdo de DataFrame na tabela especificada. Requer que o esquema de DataFrame seja o mesmo que o esquema da tabela.

Sintaxe

insertInto(tableName, overwrite=None)

Parâmetros

Parâmetro	Tipo	Descrição
tableName	str	O nome da tabela de destino.
overwrite	booleano, opcional	Se True, sobrescreve os dados existentes. Desativado por default.

Devoluções

Nenhuma

Notas

Ao contrário de DataFrameWriter.saveAsTable, DataFrameWriter.insertInto ignora os nomes das colunas e usa resolução baseada na posição.

Exemplos

Inserir dados em uma tabela usando resolução baseada em posição, ignorando os nomes das colunas.

Python

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

df.selectExpr("age AS col1", "name AS col2").write.insertInto("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |100|Alice|
# |120|Alice|
# |120|Alice|
# |140| Bob|
# |140| Bob|
# +---+------------+

spark.sql("DROP TABLE tblA")