== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#943334, add#943335, remove#943336, metaData#943337, protocol#943338, cdc#943339, checkpointMetadata#943340, sidecar#943341, domainMetadata#943342, commitInfo#943343]
Arguments: [txn#943334, add#943335, remove#943336, metaData#943337, protocol#943338, cdc#943339, checkpointMetadata#943340, sidecar#943341, domainMetadata#943342, commitInfo#943343], MapPartitionsRDD[46876] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#943334, add#943335, remove#943336, metaData#943337, protocol#943338, cdc#943339, checkpointMetadata#943340, sidecar#943341, domainMetadata#943342, commitInfo#943343]
Condition : isnotnull(add#943335)
(3) Project [codegen id : 1]
Output [11]: [add#943335.path AS path#943387, add#943335.partitionValues AS partitionValues#943388, add#943335.size AS size#943389L, add#943335.modificationTime AS modificationTime#943390L, add#943335.dataChange AS dataChange#943391, null AS stats#943398, add#943335.tags AS tags#943393, add#943335.deletionVector AS deletionVector#943394, add#943335.baseRowId AS baseRowId#943395L, add#943335.defaultRowCommitVersion AS defaultRowCommitVersion#943396L, add#943335.clusteringProvider AS clusteringProvider#943397]
Input [10]: [txn#943334, add#943335, remove#943336, metaData#943337, protocol#943338, cdc#943339, checkpointMetadata#943340, sidecar#943341, domainMetadata#943342, commitInfo#943343]