== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#10761, add#10762, remove#10763, metaData#10764, protocol#10765, cdc#10766, checkpointMetadata#10767, sidecar#10768, domainMetadata#10769, commitInfo#10770]
Arguments: [txn#10761, add#10762, remove#10763, metaData#10764, protocol#10765, cdc#10766, checkpointMetadata#10767, sidecar#10768, domainMetadata#10769, commitInfo#10770], MapPartitionsRDD[1064] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#10761, add#10762, remove#10763, metaData#10764, protocol#10765, cdc#10766, checkpointMetadata#10767, sidecar#10768, domainMetadata#10769, commitInfo#10770]
Condition : isnotnull(add#10762)
(3) Project [codegen id : 1]
Output [11]: [add#10762.path AS path#10814, add#10762.partitionValues AS partitionValues#10815, add#10762.size AS size#10816L, add#10762.modificationTime AS modificationTime#10817L, add#10762.dataChange AS dataChange#10818, null AS stats#10825, add#10762.tags AS tags#10820, add#10762.deletionVector AS deletionVector#10821, add#10762.baseRowId AS baseRowId#10822L, add#10762.defaultRowCommitVersion AS defaultRowCommitVersion#10823L, add#10762.clusteringProvider AS clusteringProvider#10824]
Input [10]: [txn#10761, add#10762, remove#10763, metaData#10764, protocol#10765, cdc#10766, checkpointMetadata#10767, sidecar#10768, domainMetadata#10769, commitInfo#10770]