Observação
O acesso a essa página exige autorização. Você pode tentar entrar ou alterar diretórios.
O acesso a essa página exige autorização. Você pode tentar alterar os diretórios.
Insere o conteúdo da DataFrame tabela especificada. Requer que o esquema do 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 |
bool, opcional | Se True, substituirá os dados existentes. Desabilitado por padrão. |
Devoluções
Nenhum
Observações
Ao contrário DataFrameWriter.saveAsTablede , DataFrameWriter.insertInto ignora nomes de coluna e usa resolução baseada em posição.
Exemplos
Insira dados em uma tabela usando a resolução baseada em posição, ignorando nomes de coluna.
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")