Det er ikke understøttet. DataFrameWriter
kan enten tilføje til eller overskrive eksisterende tabel. Hvis din ansøgning kræver mere kompleks logik, bliver du nødt til at håndtere dette manuelt.
En mulighed er at bruge en handling (foreach
, foreachPartition
) med standard JDBC-forbindelse. En anden er at skrive til en midlertidig og håndtere resten direkte i databasen.
Se også SPARK-19335 (Spark bør understøtte at lave en effektiv DataFrame Upsert via JDBC ) og relaterede forslag.