mergeInto

Funde um conjunto de atualizações, inserções e eliminações baseadas numa tabela de origem numa tabela alvo.

Sintaxe

mergeInto(table: str, condition: Column)

Parâmetros

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

Devoluções

MergeIntoWriter: MergeIntoWriter para usar além de especificar como fundir 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