Det stöds inte. DataFrameWriter
kan antingen lägga till eller skriva över befintlig tabell. Om din applikation kräver mer komplex logik måste du hantera detta manuellt.
Ett alternativ är att använda en åtgärd (foreach
, foreachPartition
) med standard JDBC-anslutning. En annan är att skriva till en temporär och hantera resten direkt i databasen.
Se även SPARK-19335 (Spark bör stödja att göra en effektiv DataFrame Upsert via JDBC ) och relaterade förslag.