mergeInto

Scala zestaw aktualizacji, wstawiania i usuwania w oparciu o tabelę źródłową do tabeli docelowej.

Składnia

mergeInto(table: str, condition: Column)

Parametry

Parameter	Typ	Opis
table	str	Nazwa tabeli docelowej do scalenia.
condition	Kolumna	Warunek określający, czy wiersz w tabeli docelowej jest zgodny z wierszem w źródłowej ramce danych.

Zwroty

MergeIntoWriter: MergeIntoWriter, aby użyć dalej, aby określić sposób scalania źródłowej ramki danych z tabelą docelową.

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