sql >> Base de Datos >  >> RDS >> PostgreSQL

Spark Dataframes UPSERT a la tabla de Postgres

No es compatible. DataFrameWriter puede agregar o sobrescribir una tabla existente. Si su aplicación requiere una lógica más compleja, tendrá que lidiar con esto manualmente.

Una opción es usar una acción (foreach , foreachPartition ) con conexión JDBC estándar. Otra es escribir en un temporal y manejar el resto directamente en la base de datos.

Consulte también SPARK-19335 (Spark debería admitir la realización de un DataFrame Upsert eficiente a través de JDBC ) y propuestas relacionadas.