== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#15458044, add#15458045, remove#15458046, metaData#15458047, protocol#15458048, cdc#15458049, checkpointMetadata#15458050, sidecar#15458051, domainMetadata#15458052, commitInfo#15458053]
Arguments: [txn#15458044, add#15458045, remove#15458046, metaData#15458047, protocol#15458048, cdc#15458049, checkpointMetadata#15458050, sidecar#15458051, domainMetadata#15458052, commitInfo#15458053], MapPartitionsRDD[884751] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#15458044, add#15458045, remove#15458046, metaData#15458047, protocol#15458048, cdc#15458049, checkpointMetadata#15458050, sidecar#15458051, domainMetadata#15458052, commitInfo#15458053]
Condition : isnotnull(add#15458045)
(3) Project [codegen id : 1]
Output [11]: [add#15458045.path AS path#15458097, add#15458045.partitionValues AS partitionValues#15458098, add#15458045.size AS size#15458099L, add#15458045.modificationTime AS modificationTime#15458100L, add#15458045.dataChange AS dataChange#15458101, null AS stats#15458108, add#15458045.tags AS tags#15458103, add#15458045.deletionVector AS deletionVector#15458104, add#15458045.baseRowId AS baseRowId#15458105L, add#15458045.defaultRowCommitVersion AS defaultRowCommitVersion#15458106L, add#15458045.clusteringProvider AS clusteringProvider#15458107]
Input [10]: [txn#15458044, add#15458045, remove#15458046, metaData#15458047, protocol#15458048, cdc#15458049, checkpointMetadata#15458050, sidecar#15458051, domainMetadata#15458052, commitInfo#15458053]