== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#23517, add#23518, remove#23519, metaData#23520, protocol#23521, cdc#23522, checkpointMetadata#23523, sidecar#23524, domainMetadata#23525, commitInfo#23526]
Arguments: [txn#23517, add#23518, remove#23519, metaData#23520, protocol#23521, cdc#23522, checkpointMetadata#23523, sidecar#23524, domainMetadata#23525, commitInfo#23526], MapPartitionsRDD[2336] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#23517, add#23518, remove#23519, metaData#23520, protocol#23521, cdc#23522, checkpointMetadata#23523, sidecar#23524, domainMetadata#23525, commitInfo#23526]
Condition : isnotnull(add#23518)
(3) Project [codegen id : 1]
Output [11]: [add#23518.path AS path#23570, add#23518.partitionValues AS partitionValues#23571, add#23518.size AS size#23572L, add#23518.modificationTime AS modificationTime#23573L, add#23518.dataChange AS dataChange#23574, null AS stats#23581, add#23518.tags AS tags#23576, add#23518.deletionVector AS deletionVector#23577, add#23518.baseRowId AS baseRowId#23578L, add#23518.defaultRowCommitVersion AS defaultRowCommitVersion#23579L, add#23518.clusteringProvider AS clusteringProvider#23580]
Input [10]: [txn#23517, add#23518, remove#23519, metaData#23520, protocol#23521, cdc#23522, checkpointMetadata#23523, sidecar#23524, domainMetadata#23525, commitInfo#23526]