DeleteFromTableExec is a V2CommandExec for DeleteFromTable logical operators at execution.
DeleteFromTableExec takes the following to be created:
- Table that SupportsDelete
- Condition Filters
- Refresh Cache Function (
() => Unit)
DeleteFromTableExec is created when:
- DataSourceV2Strategy execution planning strategy is executed (and plans DeleteFromTable logical operators)
run is part of the V2CommandExec abstraction.
run requests the table to deleteWhere with the condition.
In the end,
run calls the refresh cache function.