== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#835043, add#835044, remove#835045, metaData#835046, protocol#835047, cdc#835048, checkpointMetadata#835049, sidecar#835050, domainMetadata#835051, commitInfo#835052]
Arguments: [txn#835043, add#835044, remove#835045, metaData#835046, protocol#835047, cdc#835048, checkpointMetadata#835049, sidecar#835050, domainMetadata#835051, commitInfo#835052], MapPartitionsRDD[39187] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#835043, add#835044, remove#835045, metaData#835046, protocol#835047, cdc#835048, checkpointMetadata#835049, sidecar#835050, domainMetadata#835051, commitInfo#835052]
Condition : isnotnull(add#835044)
(3) Project [codegen id : 1]
Output [11]: [add#835044.path AS path#835096, add#835044.partitionValues AS partitionValues#835097, add#835044.size AS size#835098L, add#835044.modificationTime AS modificationTime#835099L, add#835044.dataChange AS dataChange#835100, add#835044.stats AS stats#835101, add#835044.tags AS tags#835102, add#835044.deletionVector AS deletionVector#835103, add#835044.baseRowId AS baseRowId#835104L, add#835044.defaultRowCommitVersion AS defaultRowCommitVersion#835105L, add#835044.clusteringProvider AS clusteringProvider#835106]
Input [10]: [txn#835043, add#835044, remove#835045, metaData#835046, protocol#835047, cdc#835048, checkpointMetadata#835049, sidecar#835050, domainMetadata#835051, commitInfo#835052]