Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Führt eine Reihe von Aktualisierungen, Einfügungen und Löschungen basierend auf einer Quelltabelle in eine Zieltabelle zusammen.
Syntax
mergeInto(table: str, condition: Column)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
table |
str | Zieltabellenname, in der zusammengeführt werden soll. |
condition |
Kolumne | Die Bedingung, die bestimmt, ob eine Zeile in der Zieltabelle einem im Quelldatenframe entspricht. |
Rückkehr
MergeIntoWriter: MergeIntoWriter wird weiter verwendet, um anzugeben, wie das Quelldatenmodell in die Zieltabelle zusammengeführt werden soll.
Beispiele
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())