mergeInto

Menggabungkan serangkaian pembaruan, penyisipan, dan penghapusan berdasarkan tabel sumber ke dalam tabel target.

Sintaksis

mergeInto(table: str, condition: Column)

Parameter-parameternya

Parameter	Tipe	Deskripsi
table	str	Nama tabel target untuk digabungkan.
condition	kolom	Kondisi yang menentukan apakah baris dalam tabel target cocok dengan baris di DataFrame sumber.

Pengembalian Barang

MergeIntoWriter: MergeIntoWriter untuk menggunakan lebih lanjut untuk menentukan cara menggabungkan DataFrame sumber ke dalam tabel target.

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