Description
Now many datasources (delta, jdbc, hive with transaction support, kudu, etc) supports deleting/updating data. It's necessary to add related APIs in the datasource V2 API sets.
For example, we suggest add the below interface in V2 API,
SupportsDelete.java
public interface SupportsDelete { WriteBuilder delete(Filter[] filters); }
which can delete data by simple predicates (complicated cases like correlated subquery is not considered currently).
Attachments
Issue Links
- is duplicated by
-
SPARK-28909 ANSI SQL: delete and update does not support in Spark
- Resolved