mergeInto

Merge un ensemble de mises à jour, d'insertions et de suppressions basées sur une table source dans une table cible.

Syntaxe

mergeInto(table: str, condition: Column)

parameter

parameter	Type	Description
table	str	Nom de la table cible à Merge.
condition	Colonne	La condition qui détermine si une ligne dans la table cible correspond à une dans le DataFrame source.

parameter	Type	Description
table	str	Nom de la table cible à Merge.
condition	Colonne	La condition qui détermine si une ligne dans la table cible correspond à une dans le DataFrame source.

Renvoie

MergeIntoWriter: MergeIntoWriter à utiliser pour spécifier comment Merge le DataFrame source dans la table cible.

Exemples

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