mergeInto

Kaynak tabloyu temel alan bir dizi güncelleştirme, ekleme ve silmeyi hedef tabloyla birleştirir.

Sözdizimi

mergeInto(table: str, condition: Column)

Parametreler

Parametre	Türü	Açıklama
table	str	Birleştirilecek hedef tablo adı.
condition	Köşe yazısı	Hedef tablodaki bir satırın kaynak DataFrame'deki bir satırla eşleşip eşleşmediğini belirleyen koşul.

İadeler

MergeIntoWriter: Kaynak DataFrame'in hedef tabloyla nasıl birleştirileceğini belirtmek için daha fazla kullanmak üzere MergeIntoWriter.

Örnekler

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