== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1199044, add#1199045, remove#1199046, metaData#1199047, protocol#1199048, cdc#1199049, checkpointMetadata#1199050, sidecar#1199051, domainMetadata#1199052, commitInfo#1199053]
Arguments: [txn#1199044, add#1199045, remove#1199046, metaData#1199047, protocol#1199048, cdc#1199049, checkpointMetadata#1199050, sidecar#1199051, domainMetadata#1199052, commitInfo#1199053], MapPartitionsRDD[68922] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1199044, add#1199045, remove#1199046, metaData#1199047, protocol#1199048, cdc#1199049, checkpointMetadata#1199050, sidecar#1199051, domainMetadata#1199052, commitInfo#1199053]
Condition : isnotnull(add#1199045)
(3) Project [codegen id : 1]
Output [11]: [add#1199045.path AS path#1199097, add#1199045.partitionValues AS partitionValues#1199098, add#1199045.size AS size#1199099L, add#1199045.modificationTime AS modificationTime#1199100L, add#1199045.dataChange AS dataChange#1199101, add#1199045.stats AS stats#1199102, add#1199045.tags AS tags#1199103, add#1199045.deletionVector AS deletionVector#1199104, add#1199045.baseRowId AS baseRowId#1199105L, add#1199045.defaultRowCommitVersion AS defaultRowCommitVersion#1199106L, add#1199045.clusteringProvider AS clusteringProvider#1199107]
Input [10]: [txn#1199044, add#1199045, remove#1199046, metaData#1199047, protocol#1199048, cdc#1199049, checkpointMetadata#1199050, sidecar#1199051, domainMetadata#1199052, commitInfo#1199053]