== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#904417, add#904418, remove#904419, metaData#904420, protocol#904421, cdc#904422, checkpointMetadata#904423, sidecar#904424, domainMetadata#904425, commitInfo#904426]
Arguments: [txn#904417, add#904418, remove#904419, metaData#904420, protocol#904421, cdc#904422, checkpointMetadata#904423, sidecar#904424, domainMetadata#904425, commitInfo#904426], MapPartitionsRDD[44969] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#904417, add#904418, remove#904419, metaData#904420, protocol#904421, cdc#904422, checkpointMetadata#904423, sidecar#904424, domainMetadata#904425, commitInfo#904426]
Condition : isnotnull(add#904418)
(3) Project [codegen id : 1]
Output [11]: [add#904418.path AS path#904470, add#904418.partitionValues AS partitionValues#904471, add#904418.size AS size#904472L, add#904418.modificationTime AS modificationTime#904473L, add#904418.dataChange AS dataChange#904474, null AS stats#904481, add#904418.tags AS tags#904476, add#904418.deletionVector AS deletionVector#904477, add#904418.baseRowId AS baseRowId#904478L, add#904418.defaultRowCommitVersion AS defaultRowCommitVersion#904479L, add#904418.clusteringProvider AS clusteringProvider#904480]
Input [10]: [txn#904417, add#904418, remove#904419, metaData#904420, protocol#904421, cdc#904422, checkpointMetadata#904423, sidecar#904424, domainMetadata#904425, commitInfo#904426]