public interface ExtendedSupportsDelete
extends org.apache.spark.sql.connector.catalog.SupportsDelete
Modifier and Type | Method and Description |
---|---|
default boolean |
canDeleteWhere(org.apache.spark.sql.sources.Filter[] filters)
Checks if it is possible to delete data from a data source table that matches filter expressions.
|
default boolean canDeleteWhere(org.apache.spark.sql.sources.Filter[] filters)
Rows should be deleted from the data source iff all of the filter expressions match. That is, the expressions must be interpreted as a set of filters that are ANDed together.
Spark will call this method to check if the delete is possible without significant effort. Otherwise, Spark will try to rewrite the delete operation if the data source table supports row-level operations.
filters
- filter expressions, used to select rows to delete when all expressions match