Skip to content


DeleteFromTableExec is a V2CommandExec for DeleteFromTable logical operators at execution.

Creating Instance

DeleteFromTableExec takes the following to be created:

DeleteFromTableExec is created when:

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.