== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#26804, add#26805, remove#26806, metaData#26807, protocol#26808, cdc#26809, checkpointMetadata#26810, sidecar#26811, domainMetadata#26812, commitInfo#26813]
Arguments: [txn#26804, add#26805, remove#26806, metaData#26807, protocol#26808, cdc#26809, checkpointMetadata#26810, sidecar#26811, domainMetadata#26812, commitInfo#26813], MapPartitionsRDD[2658] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#26804, add#26805, remove#26806, metaData#26807, protocol#26808, cdc#26809, checkpointMetadata#26810, sidecar#26811, domainMetadata#26812, commitInfo#26813]
Condition : isnotnull(add#26805)
(3) Project [codegen id : 1]
Output [11]: [add#26805.path AS path#26857, add#26805.partitionValues AS partitionValues#26858, add#26805.size AS size#26859L, add#26805.modificationTime AS modificationTime#26860L, add#26805.dataChange AS dataChange#26861, add#26805.stats AS stats#26862, add#26805.tags AS tags#26863, add#26805.deletionVector AS deletionVector#26864, add#26805.baseRowId AS baseRowId#26865L, add#26805.defaultRowCommitVersion AS defaultRowCommitVersion#26866L, add#26805.clusteringProvider AS clusteringProvider#26867]
Input [10]: [txn#26804, add#26805, remove#26806, metaData#26807, protocol#26808, cdc#26809, checkpointMetadata#26810, sidecar#26811, domainMetadata#26812, commitInfo#26813]