DeleteFromTableExec¶

DeleteFromTableExec is a V2CommandExec for DeleteFromTable logical operators at execution.

Creating Instance¶

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)

Executing Command¶

run(): Seq[InternalRow]

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.