== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#834195, add#834196, remove#834197, metaData#834198, protocol#834199, cdc#834200, checkpointMetadata#834201, sidecar#834202, domainMetadata#834203, commitInfo#834204]
Arguments: [txn#834195, add#834196, remove#834197, metaData#834198, protocol#834199, cdc#834200, checkpointMetadata#834201, sidecar#834202, domainMetadata#834203, commitInfo#834204], MapPartitionsRDD[39092] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#834195, add#834196, remove#834197, metaData#834198, protocol#834199, cdc#834200, checkpointMetadata#834201, sidecar#834202, domainMetadata#834203, commitInfo#834204]
Condition : isnotnull(add#834196)
(3) Project [codegen id : 1]
Output [11]: [add#834196.path AS path#834248, add#834196.partitionValues AS partitionValues#834249, add#834196.size AS size#834250L, add#834196.modificationTime AS modificationTime#834251L, add#834196.dataChange AS dataChange#834252, add#834196.stats AS stats#834253, add#834196.tags AS tags#834254, add#834196.deletionVector AS deletionVector#834255, add#834196.baseRowId AS baseRowId#834256L, add#834196.defaultRowCommitVersion AS defaultRowCommitVersion#834257L, add#834196.clusteringProvider AS clusteringProvider#834258]
Input [10]: [txn#834195, add#834196, remove#834197, metaData#834198, protocol#834199, cdc#834200, checkpointMetadata#834201, sidecar#834202, domainMetadata#834203, commitInfo#834204]