== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#22552, add#22553, remove#22554, metaData#22555, protocol#22556, cdc#22557, checkpointMetadata#22558, sidecar#22559, domainMetadata#22560, commitInfo#22561]
Arguments: [txn#22552, add#22553, remove#22554, metaData#22555, protocol#22556, cdc#22557, checkpointMetadata#22558, sidecar#22559, domainMetadata#22560, commitInfo#22561], MapPartitionsRDD[2234] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#22552, add#22553, remove#22554, metaData#22555, protocol#22556, cdc#22557, checkpointMetadata#22558, sidecar#22559, domainMetadata#22560, commitInfo#22561]
Condition : isnotnull(add#22553)
(3) Project [codegen id : 1]
Output [11]: [add#22553.path AS path#22605, add#22553.partitionValues AS partitionValues#22606, add#22553.size AS size#22607L, add#22553.modificationTime AS modificationTime#22608L, add#22553.dataChange AS dataChange#22609, add#22553.stats AS stats#22610, add#22553.tags AS tags#22611, add#22553.deletionVector AS deletionVector#22612, add#22553.baseRowId AS baseRowId#22613L, add#22553.defaultRowCommitVersion AS defaultRowCommitVersion#22614L, add#22553.clusteringProvider AS clusteringProvider#22615]
Input [10]: [txn#22552, add#22553, remove#22554, metaData#22555, protocol#22556, cdc#22557, checkpointMetadata#22558, sidecar#22559, domainMetadata#22560, commitInfo#22561]