== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1127027, add#1127028, remove#1127029, metaData#1127030, protocol#1127031, cdc#1127032, checkpointMetadata#1127033, sidecar#1127034, domainMetadata#1127035, commitInfo#1127036]
Arguments: [txn#1127027, add#1127028, remove#1127029, metaData#1127030, protocol#1127031, cdc#1127032, checkpointMetadata#1127033, sidecar#1127034, domainMetadata#1127035, commitInfo#1127036], MapPartitionsRDD[64962] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1127027, add#1127028, remove#1127029, metaData#1127030, protocol#1127031, cdc#1127032, checkpointMetadata#1127033, sidecar#1127034, domainMetadata#1127035, commitInfo#1127036]
Condition : isnotnull(add#1127028)
(3) Project [codegen id : 1]
Output [11]: [add#1127028.path AS path#1127080, add#1127028.partitionValues AS partitionValues#1127081, add#1127028.size AS size#1127082L, add#1127028.modificationTime AS modificationTime#1127083L, add#1127028.dataChange AS dataChange#1127084, add#1127028.stats AS stats#1127085, add#1127028.tags AS tags#1127086, add#1127028.deletionVector AS deletionVector#1127087, add#1127028.baseRowId AS baseRowId#1127088L, add#1127028.defaultRowCommitVersion AS defaultRowCommitVersion#1127089L, add#1127028.clusteringProvider AS clusteringProvider#1127090]
Input [10]: [txn#1127027, add#1127028, remove#1127029, metaData#1127030, protocol#1127031, cdc#1127032, checkpointMetadata#1127033, sidecar#1127034, domainMetadata#1127035, commitInfo#1127036]