mesclar em

Mesclar um conjunto de atualizações, inserções e exclusões de 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 merge .
condition	Coluna	A condição que determina se uma linha na tabela de destino corresponde a uma linha no DataFrame de origem.

Devoluções

MergeIntoWriter: O MergeIntoWriter deve ser usado posteriormente para especificar como merge o DataFrame de origem na tabela de destino.

Exemplos

Python

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())