Compartilhar via

mergeInto

Mescla um conjunto de atualizações, inserções e exclusões com base em uma tabela de origem em uma tabela de destino.

Sintaxe

mergeInto(table: str, condition: Column)

Parâmetros

Parâmetro Tipo Descrição
table str Nome da tabela de destino para mesclar.
condition Coluna A condição que determina se uma linha na tabela de destino corresponde a uma no DataFrame de origem.

Devoluções

MergeIntoWriter: MergeIntoWriter para usar ainda mais para especificar como mesclar o DataFrame de origem na tabela de destino.

Exemplos

from pyspark.sql.functions import expr
source = spark.createDataFrame(
    [(14, "Tom"), (23, "Alice"), (16, "Bob")], ["id", "name"])
(source.mergeInto("target", "id")
    .whenMatched().update({ "name": source.name })
    .whenNotMatched().insertAll()
    .whenNotMatchedBySource().delete()
    .merge())
  • Last updated on