== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#739831, add#739832, remove#739833, metaData#739834, protocol#739835, cdc#739836, checkpointMetadata#739837, sidecar#739838, domainMetadata#739839, commitInfo#739840]
Arguments: [txn#739831, add#739832, remove#739833, metaData#739834, protocol#739835, cdc#739836, checkpointMetadata#739837, sidecar#739838, domainMetadata#739839, commitInfo#739840], MapPartitionsRDD[34778] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#739831, add#739832, remove#739833, metaData#739834, protocol#739835, cdc#739836, checkpointMetadata#739837, sidecar#739838, domainMetadata#739839, commitInfo#739840]
Condition : isnotnull(add#739832)
(3) Project [codegen id : 1]
Output [11]: [add#739832.path AS path#739884, add#739832.partitionValues AS partitionValues#739885, add#739832.size AS size#739886L, add#739832.modificationTime AS modificationTime#739887L, add#739832.dataChange AS dataChange#739888, add#739832.stats AS stats#739889, add#739832.tags AS tags#739890, add#739832.deletionVector AS deletionVector#739891, add#739832.baseRowId AS baseRowId#739892L, add#739832.defaultRowCommitVersion AS defaultRowCommitVersion#739893L, add#739832.clusteringProvider AS clusteringProvider#739894]
Input [10]: [txn#739831, add#739832, remove#739833, metaData#739834, protocol#739835, cdc#739836, checkpointMetadata#739837, sidecar#739838, domainMetadata#739839, commitInfo#739840]