Skip to content

DeleteCommand

DeleteCommand is a <> that <>.

DeleteCommand is <> (using <> factory utility) and <> when <> operator is used (indirectly through 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 <> for the <>.

run requests the DeltaLog to <> for <>.

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 <>.


Last update: 2020-09-24