== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#21530158, add#21530159, remove#21530160, metaData#21530161, protocol#21530162, cdc#21530163, checkpointMetadata#21530164, sidecar#21530165, domainMetadata#21530166, commitInfo#21530167]
Arguments: [txn#21530158, add#21530159, remove#21530160, metaData#21530161, protocol#21530162, cdc#21530163, checkpointMetadata#21530164, sidecar#21530165, domainMetadata#21530166, commitInfo#21530167], MapPartitionsRDD[1241926] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#21530158, add#21530159, remove#21530160, metaData#21530161, protocol#21530162, cdc#21530163, checkpointMetadata#21530164, sidecar#21530165, domainMetadata#21530166, commitInfo#21530167]
Condition : isnotnull(add#21530159)
(3) Project [codegen id : 1]
Output [11]: [add#21530159.path AS path#21530211, add#21530159.partitionValues AS partitionValues#21530212, add#21530159.size AS size#21530213L, add#21530159.modificationTime AS modificationTime#21530214L, add#21530159.dataChange AS dataChange#21530215, add#21530159.stats AS stats#21530216, add#21530159.tags AS tags#21530217, add#21530159.deletionVector AS deletionVector#21530218, add#21530159.baseRowId AS baseRowId#21530219L, add#21530159.defaultRowCommitVersion AS defaultRowCommitVersion#21530220L, add#21530159.clusteringProvider AS clusteringProvider#21530221]
Input [10]: [txn#21530158, add#21530159, remove#21530160, metaData#21530161, protocol#21530162, cdc#21530163, checkpointMetadata#21530164, sidecar#21530165, domainMetadata#21530166, commitInfo#21530167]