Row-Level Operations (no native implementations available)

Author: jaceklaskowski

docs/connector/RowLevelOperation.md

@@ -0,0 +1,3 @@
+# RowLevelOperation
+
+`RowLevelOperation` is...FIXME

docs/connector/SupportsDelta.md

@@ -0,0 +1,27 @@
+---
+title: SupportsDelta
+---
+
+# SupportsDelta Row-Level Operations
+
+`SupportsDelta` is an [extension](#contract) of the [RowLevelOperation](RowLevelOperation.md) abstraction for [row-level operations](#implementations) with [rowId](#rowId).
+
+## Contract (Subset)
+
+### rowId { #rowId }
+
+```java
+NamedReference[] rowId()
+```
+
+row ID column references for row equality
+
+Used when:
+
+* [RewriteRowLevelCommand](../logical-analysis-rules/RewriteRowLevelCommand.md) logical analysis rule is executed (and [resolveRowIdAttrs](../logical-analysis-rules/RewriteRowLevelCommand.md#resolveRowIdAttrs))
+* [WriteDelta](../logical-operators/WriteDelta.md) logical operator is executed (and [rowIdAttrsResolved](../logical-operators/WriteDelta.md#rowIdAttrsResolved))
+
+## Implementations
+
+!!! note
+    No built-in implementations available.

docs/logical-operators/RowLevelWrite.md

@@ -4,4 +4,30 @@ title: RowLevelWrite
 
 # RowLevelWrite Logical Operators
 
-`RowLevelWrite` is...FIXME
+`RowLevelWrite` is an [extension](#contract) of the [V2WriteCommand](V2WriteCommand.md) abstraction for [write commands](#implementations) with [SupportsSubquery](SupportsSubquery.md).
+
+## Contract (Subset)
+
+### operation
+
+```scala
+operation: RowLevelOperation
+```
+
+See:
+
+* [ReplaceData](ReplaceData.md#operation)
+* [WriteDelta](WriteDelta.md#operation)
+
+Used when:
+
+* `GroupBasedRowLevelOperation` is requested to `unapply`
+* `WriteDelta` is requested to [metadataAttrsResolved](WriteDelta.md#metadataAttrsResolved), [rowIdAttrsResolved](WriteDelta.md#rowIdAttrsResolved)
+* `GroupBasedRowLevelOperationScanPlanning` is requested to [apply](../logical-optimizations/GroupBasedRowLevelOperationScanPlanning.md#apply)
+* `RewrittenRowLevelCommand` is requested to `unapply`
+* `RowLevelOperationRuntimeGroupFiltering` is requested to `apply`
+
+## Implementations
+
+* [ReplaceData](ReplaceData.md)
+* [WriteDelta](WriteDelta.md)

docs/logical-operators/WriteDelta.md

@@ -4,4 +4,25 @@ title: WriteDelta
 
 # WriteDelta Logical Operator
 
-`WriteDelta` is...FIXME
+`WriteDelta` is a [RowLevelWrite](RowLevelWrite.md) logical operator.
+
+## Creating Instance
+
+`WriteDelta` takes the following to be created:
+
+* <span id="table"> Table ([NamedRelation](NamedRelation.md))
+* <span id="condition"> Condition ([Expression](../expressions/Expression.md))
+* <span id="query"> Query ([LogicalPlan](LogicalPlan.md))
+* <span id="originalTable"> Original Table ([NamedRelation](NamedRelation.md))
+* <span id="projections"> `WriteDeltaProjections`
+* <span id="write"> `DeltaWrite`
+
+`WriteDelta` is created when:
+
+* [RewriteDeleteFromTable](../logical-analysis-rules/RewriteDeleteFromTable.md) logical analysis rule is executed (and requested to [buildWriteDeltaPlan](../logical-analysis-rules/RewriteDeleteFromTable.md#buildWriteDeltaPlan) for [SupportsDelta](../connector/SupportsDelta.md) row-level operations)
+* `RewriteMergeIntoTable` logical analysis rule is executed (and `buildWriteDeltaPlan` for [SupportsDelta](../connector/SupportsDelta.md) row-level operations)
+* `RewriteUpdateTable` logical analysis rule is executed (and `buildWriteDeltaPlan` for [SupportsDelta](../connector/SupportsDelta.md) row-level operations)
+
+## Query Planning
+
+`WriteDelta` is planned to [WriteDeltaExec](../physical-operators/WriteDeltaExec.md) physical operator by [DataSourceV2Strategy](../execution-planning-strategies/DataSourceV2Strategy.md) execution planning strategy.

docs/physical-operators/V2ExistingTableWriteExec.md

@@ -18,7 +18,7 @@ Used when:
 
 * `V2ExistingTableWriteExec` is [executed](#run)
 
-### write { #write }
+### write
 
 ```scala
 write: Write
@@ -32,11 +32,9 @@ Used when:
 
 ## Implementations
 
-* `AppendDataExec`
 * [OverwriteByExpressionExec](OverwriteByExpressionExec.md)
-* `OverwritePartitionsDynamicExec`
-* `ReplaceDataExec`
-* `WriteDeltaExec`
+* [WriteDeltaExec](WriteDeltaExec.md)
+* _others_
 
 ## Executing Command { #run }
 

docs/physical-operators/WriteDeltaExec.md

@@ -0,0 +1,20 @@
+---
+title: WriteDeltaExec
+---
+
+# WriteDeltaExec Physical Operator
+
+`WriteDeltaExec` is a [V2ExistingTableWriteExec](V2ExistingTableWriteExec.md) physical operator that represents a [WriteDelta](../logical-operators/WriteDelta.md) logical operator at execution time.
+
+## Creating Instance
+
+`WriteDeltaExec` takes the following to be created:
+
+* <span id="query"> Query Physical Plan ([SparkPlan](SparkPlan.md))
+* <span id="refreshCache"> `refreshCache` function (`() => Unit`)
+* <span id="projections"> `WriteDeltaProjections`
+* <span id="write"> `DeltaWrite`
+
+`WriteDeltaExec` is created when:
+
+* [DataSourceV2Strategy](../execution-planning-strategies/DataSourceV2Strategy.md) execution planning strategy is executed (to plan a [WriteDelta](../logical-operators/WriteDelta.md) logical operator)

mkdocs.yml

@@ -456,6 +456,7 @@ nav:
       - WindowExec:
         - WindowExec: physical-operators/WindowExec.md
       - WindowExecBase: physical-operators/WindowExecBase.md
+      - WriteDeltaExec: physical-operators/WriteDeltaExec.md
       - WriteFilesExec: physical-operators/WriteFilesExec.md
       - Distribution and Partitioning:
         - Distribution: physical-operators/Distribution.md