== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13801734, add#13801735, remove#13801736, metaData#13801737, protocol#13801738, cdc#13801739, checkpointMetadata#13801740, sidecar#13801741, domainMetadata#13801742, commitInfo#13801743]
Arguments: [txn#13801734, add#13801735, remove#13801736, metaData#13801737, protocol#13801738, cdc#13801739, checkpointMetadata#13801740, sidecar#13801741, domainMetadata#13801742, commitInfo#13801743], MapPartitionsRDD[789599] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13801734, add#13801735, remove#13801736, metaData#13801737, protocol#13801738, cdc#13801739, checkpointMetadata#13801740, sidecar#13801741, domainMetadata#13801742, commitInfo#13801743]
Condition : isnotnull(add#13801735)
(3) Project [codegen id : 1]
Output [11]: [add#13801735.path AS path#13801787, add#13801735.partitionValues AS partitionValues#13801788, add#13801735.size AS size#13801789L, add#13801735.modificationTime AS modificationTime#13801790L, add#13801735.dataChange AS dataChange#13801791, add#13801735.stats AS stats#13801792, add#13801735.tags AS tags#13801793, add#13801735.deletionVector AS deletionVector#13801794, add#13801735.baseRowId AS baseRowId#13801795L, add#13801735.defaultRowCommitVersion AS defaultRowCommitVersion#13801796L, add#13801735.clusteringProvider AS clusteringProvider#13801797]
Input [10]: [txn#13801734, add#13801735, remove#13801736, metaData#13801737, protocol#13801738, cdc#13801739, checkpointMetadata#13801740, sidecar#13801741, domainMetadata#13801742, commitInfo#13801743]