== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#724595, add#724596, remove#724597, metaData#724598, protocol#724599, cdc#724600, checkpointMetadata#724601, sidecar#724602, domainMetadata#724603, commitInfo#724604]
Arguments: [txn#724595, add#724596, remove#724597, metaData#724598, protocol#724599, cdc#724600, checkpointMetadata#724601, sidecar#724602, domainMetadata#724603, commitInfo#724604], MapPartitionsRDD[34143] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#724595, add#724596, remove#724597, metaData#724598, protocol#724599, cdc#724600, checkpointMetadata#724601, sidecar#724602, domainMetadata#724603, commitInfo#724604]
Condition : isnotnull(add#724596)
(3) Project [codegen id : 1]
Output [11]: [add#724596.path AS path#724648, add#724596.partitionValues AS partitionValues#724649, add#724596.size AS size#724650L, add#724596.modificationTime AS modificationTime#724651L, add#724596.dataChange AS dataChange#724652, add#724596.stats AS stats#724653, add#724596.tags AS tags#724654, add#724596.deletionVector AS deletionVector#724655, add#724596.baseRowId AS baseRowId#724656L, add#724596.defaultRowCommitVersion AS defaultRowCommitVersion#724657L, add#724596.clusteringProvider AS clusteringProvider#724658]
Input [10]: [txn#724595, add#724596, remove#724597, metaData#724598, protocol#724599, cdc#724600, checkpointMetadata#724601, sidecar#724602, domainMetadata#724603, commitInfo#724604]