== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#824652, add#824653, remove#824654, metaData#824655, protocol#824656, cdc#824657, checkpointMetadata#824658, sidecar#824659, domainMetadata#824660, commitInfo#824661]
Arguments: [txn#824652, add#824653, remove#824654, metaData#824655, protocol#824656, cdc#824657, checkpointMetadata#824658, sidecar#824659, domainMetadata#824660, commitInfo#824661], MapPartitionsRDD[38646] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#824652, add#824653, remove#824654, metaData#824655, protocol#824656, cdc#824657, checkpointMetadata#824658, sidecar#824659, domainMetadata#824660, commitInfo#824661]
Condition : isnotnull(add#824653)
(3) Project [codegen id : 1]
Output [11]: [add#824653.path AS path#824705, add#824653.partitionValues AS partitionValues#824706, add#824653.size AS size#824707L, add#824653.modificationTime AS modificationTime#824708L, add#824653.dataChange AS dataChange#824709, null AS stats#824716, add#824653.tags AS tags#824711, add#824653.deletionVector AS deletionVector#824712, add#824653.baseRowId AS baseRowId#824713L, add#824653.defaultRowCommitVersion AS defaultRowCommitVersion#824714L, add#824653.clusteringProvider AS clusteringProvider#824715]
Input [10]: [txn#824652, add#824653, remove#824654, metaData#824655, protocol#824656, cdc#824657, checkpointMetadata#824658, sidecar#824659, domainMetadata#824660, commitInfo#824661]