Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Sammanfogar en uppsättning uppdateringar, infogningar och borttagningar baserat på en källtabell till en måltabell.
Syntax
mergeInto(table: str, condition: Column)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
table |
str | Måltabellens namn som ska sammanfogas till. |
condition |
Kolumn | Villkoret som avgör om en rad i måltabellen matchar en i källdataramen. |
Retur
MergeIntoWriter: MergeIntoWriter för att använda ytterligare för att ange hur källdataramen ska sammanfogas till måltabellen.
Exempel
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())