== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#24678, add#24679, remove#24680, metaData#24681, protocol#24682, cdc#24683, checkpointMetadata#24684, sidecar#24685, domainMetadata#24686, commitInfo#24687]
Arguments: [txn#24678, add#24679, remove#24680, metaData#24681, protocol#24682, cdc#24683, checkpointMetadata#24684, sidecar#24685, domainMetadata#24686, commitInfo#24687], MapPartitionsRDD[2446] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#24678, add#24679, remove#24680, metaData#24681, protocol#24682, cdc#24683, checkpointMetadata#24684, sidecar#24685, domainMetadata#24686, commitInfo#24687]
Condition : isnotnull(add#24679)
(3) Project [codegen id : 1]
Output [11]: [add#24679.path AS path#24731, add#24679.partitionValues AS partitionValues#24732, add#24679.size AS size#24733L, add#24679.modificationTime AS modificationTime#24734L, add#24679.dataChange AS dataChange#24735, add#24679.stats AS stats#24736, add#24679.tags AS tags#24737, add#24679.deletionVector AS deletionVector#24738, add#24679.baseRowId AS baseRowId#24739L, add#24679.defaultRowCommitVersion AS defaultRowCommitVersion#24740L, add#24679.clusteringProvider AS clusteringProvider#24741]
Input [10]: [txn#24678, add#24679, remove#24680, metaData#24681, protocol#24682, cdc#24683, checkpointMetadata#24684, sidecar#24685, domainMetadata#24686, commitInfo#24687]