== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1021256, add#1021257, remove#1021258, metaData#1021259, protocol#1021260, cdc#1021261, checkpointMetadata#1021262, sidecar#1021263, domainMetadata#1021264, commitInfo#1021265]
Arguments: [txn#1021256, add#1021257, remove#1021258, metaData#1021259, protocol#1021260, cdc#1021261, checkpointMetadata#1021262, sidecar#1021263, domainMetadata#1021264, commitInfo#1021265], MapPartitionsRDD[50969] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1021256, add#1021257, remove#1021258, metaData#1021259, protocol#1021260, cdc#1021261, checkpointMetadata#1021262, sidecar#1021263, domainMetadata#1021264, commitInfo#1021265]
Condition : isnotnull(add#1021257)
(3) Project [codegen id : 1]
Output [11]: [add#1021257.path AS path#1021309, add#1021257.partitionValues AS partitionValues#1021310, add#1021257.size AS size#1021311L, add#1021257.modificationTime AS modificationTime#1021312L, add#1021257.dataChange AS dataChange#1021313, add#1021257.stats AS stats#1021314, add#1021257.tags AS tags#1021315, add#1021257.deletionVector AS deletionVector#1021316, add#1021257.baseRowId AS baseRowId#1021317L, add#1021257.defaultRowCommitVersion AS defaultRowCommitVersion#1021318L, add#1021257.clusteringProvider AS clusteringProvider#1021319]
Input [10]: [txn#1021256, add#1021257, remove#1021258, metaData#1021259, protocol#1021260, cdc#1021261, checkpointMetadata#1021262, sidecar#1021263, domainMetadata#1021264, commitInfo#1021265]