== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#9796, add#9797, remove#9798, metaData#9799, protocol#9800, cdc#9801, checkpointMetadata#9802, sidecar#9803, domainMetadata#9804, commitInfo#9805]
Arguments: [txn#9796, add#9797, remove#9798, metaData#9799, protocol#9800, cdc#9801, checkpointMetadata#9802, sidecar#9803, domainMetadata#9804, commitInfo#9805], MapPartitionsRDD[962] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#9796, add#9797, remove#9798, metaData#9799, protocol#9800, cdc#9801, checkpointMetadata#9802, sidecar#9803, domainMetadata#9804, commitInfo#9805]
Condition : isnotnull(add#9797)
(3) Project [codegen id : 1]
Output [11]: [add#9797.path AS path#9849, add#9797.partitionValues AS partitionValues#9850, add#9797.size AS size#9851L, add#9797.modificationTime AS modificationTime#9852L, add#9797.dataChange AS dataChange#9853, add#9797.stats AS stats#9854, add#9797.tags AS tags#9855, add#9797.deletionVector AS deletionVector#9856, add#9797.baseRowId AS baseRowId#9857L, add#9797.defaultRowCommitVersion AS defaultRowCommitVersion#9858L, add#9797.clusteringProvider AS clusteringProvider#9859]
Input [10]: [txn#9796, add#9797, remove#9798, metaData#9799, protocol#9800, cdc#9801, checkpointMetadata#9802, sidecar#9803, domainMetadata#9804, commitInfo#9805]