DeleteCommand is a
RunnableCommand logical operator (Spark SQL).
DeleteCommand takes the following to be created:
DeleteCommand is created (also using apply factory utility) when:
- PreprocessTableDelete logical resolution rule is executed (and resolves a DeltaDelete logical command)
| ||number of files removed.|
| ||number of files added.|
| ||number of rows deleted.|
run( sparkSession: SparkSession): Seq[Row]
run is part of the
RunnableCommand (Spark SQL) abstraction.
performDelete( sparkSession: SparkSession, deltaLog: DeltaLog, txn: OptimisticTransaction): Unit
apply( delete: DeltaDelete): DeleteCommand
apply creates a DeleteCommand.