mergeInto

Voegt een set updates, invoegingen en verwijderingen samen op basis van een brontabel in een doeltabel.

Syntaxis

mergeInto(table: str, condition: Column)

Parameterwaarden

Kenmerk Typ Beschrijving
table str Naam van doeltabel om samen te voegen in.
condition Rubriek De voorwaarde die bepaalt of een rij in de doeltabel overeenkomt met een rij in het dataframe van de bron.

Retouren

MergeIntoWriter: MergeIntoWriter om verder te gebruiken om op te geven hoe het brondataframe moet worden samengevoegd in de doeltabel.

Examples

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