== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#6509, add#6510, remove#6511, metaData#6512, protocol#6513, cdc#6514, checkpointMetadata#6515, sidecar#6516, domainMetadata#6517, commitInfo#6518]
Arguments: [txn#6509, add#6510, remove#6511, metaData#6512, protocol#6513, cdc#6514, checkpointMetadata#6515, sidecar#6516, domainMetadata#6517, commitInfo#6518], MapPartitionsRDD[640] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#6509, add#6510, remove#6511, metaData#6512, protocol#6513, cdc#6514, checkpointMetadata#6515, sidecar#6516, domainMetadata#6517, commitInfo#6518]
Condition : isnotnull(add#6510)
(3) Project [codegen id : 1]
Output [11]: [add#6510.path AS path#6562, add#6510.partitionValues AS partitionValues#6563, add#6510.size AS size#6564L, add#6510.modificationTime AS modificationTime#6565L, add#6510.dataChange AS dataChange#6566, null AS stats#6573, add#6510.tags AS tags#6568, add#6510.deletionVector AS deletionVector#6569, add#6510.baseRowId AS baseRowId#6570L, add#6510.defaultRowCommitVersion AS defaultRowCommitVersion#6571L, add#6510.clusteringProvider AS clusteringProvider#6572]
Input [10]: [txn#6509, add#6510, remove#6511, metaData#6512, protocol#6513, cdc#6514, checkpointMetadata#6515, sidecar#6516, domainMetadata#6517, commitInfo#6518]