== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#922514, add#922515, remove#922516, metaData#922517, protocol#922518, cdc#922519, checkpointMetadata#922520, sidecar#922521, domainMetadata#922522, commitInfo#922523]
Arguments: [txn#922514, add#922515, remove#922516, metaData#922517, protocol#922518, cdc#922519, checkpointMetadata#922520, sidecar#922521, domainMetadata#922522, commitInfo#922523], MapPartitionsRDD[43253] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#922514, add#922515, remove#922516, metaData#922517, protocol#922518, cdc#922519, checkpointMetadata#922520, sidecar#922521, domainMetadata#922522, commitInfo#922523]
Condition : isnotnull(add#922515)
(3) Project [codegen id : 1]
Output [11]: [add#922515.path AS path#922567, add#922515.partitionValues AS partitionValues#922568, add#922515.size AS size#922569L, add#922515.modificationTime AS modificationTime#922570L, add#922515.dataChange AS dataChange#922571, add#922515.stats AS stats#922572, add#922515.tags AS tags#922573, add#922515.deletionVector AS deletionVector#922574, add#922515.baseRowId AS baseRowId#922575L, add#922515.defaultRowCommitVersion AS defaultRowCommitVersion#922576L, add#922515.clusteringProvider AS clusteringProvider#922577]
Input [10]: [txn#922514, add#922515, remove#922516, metaData#922517, protocol#922518, cdc#922519, checkpointMetadata#922520, sidecar#922521, domainMetadata#922522, commitInfo#922523]