DeleteCommand is a
RunnableCommand (Spark SQL) logical operator.
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
Number of Table Files¶
Finding Delete Actions¶
performDelete branches off based on the optional condition:
Delete Condition Undefined¶
Metadata-Only Delete Condition¶
Other Delete Conditions¶
Delete Actions Available¶
apply( delete: DeltaDelete): DeleteCommand
apply creates a DeleteCommand.