== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#22454, add#22455, remove#22456, metaData#22457, protocol#22458, cdc#22459, checkpointMetadata#22460, sidecar#22461, domainMetadata#22462, commitInfo#22463]
Arguments: [txn#22454, add#22455, remove#22456, metaData#22457, protocol#22458, cdc#22459, checkpointMetadata#22460, sidecar#22461, domainMetadata#22462, commitInfo#22463], MapPartitionsRDD[2230] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#22454, add#22455, remove#22456, metaData#22457, protocol#22458, cdc#22459, checkpointMetadata#22460, sidecar#22461, domainMetadata#22462, commitInfo#22463]
Condition : isnotnull(add#22455)
(3) Project [codegen id : 1]
Output [11]: [add#22455.path AS path#22507, add#22455.partitionValues AS partitionValues#22508, add#22455.size AS size#22509L, add#22455.modificationTime AS modificationTime#22510L, add#22455.dataChange AS dataChange#22511, null AS stats#22518, add#22455.tags AS tags#22513, add#22455.deletionVector AS deletionVector#22514, add#22455.baseRowId AS baseRowId#22515L, add#22455.defaultRowCommitVersion AS defaultRowCommitVersion#22516L, add#22455.clusteringProvider AS clusteringProvider#22517]
Input [10]: [txn#22454, add#22455, remove#22456, metaData#22457, protocol#22458, cdc#22459, checkpointMetadata#22460, sidecar#22461, domainMetadata#22462, commitInfo#22463]