== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#21391, add#21392, remove#21393, metaData#21394, protocol#21395, cdc#21396, checkpointMetadata#21397, sidecar#21398, domainMetadata#21399, commitInfo#21400]
Arguments: [txn#21391, add#21392, remove#21393, metaData#21394, protocol#21395, cdc#21396, checkpointMetadata#21397, sidecar#21398, domainMetadata#21399, commitInfo#21400], MapPartitionsRDD[2124] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#21391, add#21392, remove#21393, metaData#21394, protocol#21395, cdc#21396, checkpointMetadata#21397, sidecar#21398, domainMetadata#21399, commitInfo#21400]
Condition : isnotnull(add#21392)
(3) Project [codegen id : 1]
Output [11]: [add#21392.path AS path#21444, add#21392.partitionValues AS partitionValues#21445, add#21392.size AS size#21446L, add#21392.modificationTime AS modificationTime#21447L, add#21392.dataChange AS dataChange#21448, null AS stats#21455, add#21392.tags AS tags#21450, add#21392.deletionVector AS deletionVector#21451, add#21392.baseRowId AS baseRowId#21452L, add#21392.defaultRowCommitVersion AS defaultRowCommitVersion#21453L, add#21392.clusteringProvider AS clusteringProvider#21454]
Input [10]: [txn#21391, add#21392, remove#21393, metaData#21394, protocol#21395, cdc#21396, checkpointMetadata#21397, sidecar#21398, domainMetadata#21399, commitInfo#21400]