Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Unisce un set di aggiornamenti, inserimenti ed eliminazioni in base a una tabella di origine in una tabella di destinazione.
Sintassi
mergeInto(table: str, condition: Column)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
table |
str | Nome della tabella di destinazione in cui eseguire l'unione. |
condition |
colonna | Condizione che determina se una riga nella tabella di destinazione corrisponde a una riga nel dataframe di origine. |
Restituzioni
MergeIntoWriter: MergeIntoWriter da usare per specificare come unire il dataframe di origine nella tabella di destinazione.
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())