DeleteCommand¶
DeleteCommand
is a <
DeleteCommand
is <DeltaTableOperations
when requested to <
== [[creating-instance]] Creating DeleteCommand Instance
DeleteCommand
takes the following to be created:
- [[tahoeFileIndex]]
TahoeFileIndex
- [[target]] Target
LogicalPlan
- [[condition]] Optional Catalyst expression
== [[apply]] Creating DeleteCommand Instance -- apply
Factory Utility
[source, scala]¶
apply(delete: Delete): DeleteCommand¶
apply
...FIXME
NOTE: apply
is used when...FIXME
== [[run]] Running Command -- run
Method
[source, scala]¶
run(sparkSession: SparkSession): Seq[Row]¶
NOTE: run
is part of the RunnableCommand
contract to...FIXME.
run
requests the <
run
requests the DeltaLog
to <
In the end, run
re-caches all cached plans (incl. this relation itself) by requesting the CacheManager
to recache the <
== [[performDelete]] performDelete
Internal Method
[source, scala]¶
performDelete( sparkSession: SparkSession, deltaLog: DeltaLog, txn: OptimisticTransaction): Unit
performDelete
...FIXME
NOTE: performDelete
is used exclusively when DeleteCommand
is requested to <