== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#914751, add#914752, remove#914753, metaData#914754, protocol#914755, cdc#914756, checkpointMetadata#914757, sidecar#914758, domainMetadata#914759, commitInfo#914760]
Arguments: [txn#914751, add#914752, remove#914753, metaData#914754, protocol#914755, cdc#914756, checkpointMetadata#914757, sidecar#914758, domainMetadata#914759, commitInfo#914760], MapPartitionsRDD[45462] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#914751, add#914752, remove#914753, metaData#914754, protocol#914755, cdc#914756, checkpointMetadata#914757, sidecar#914758, domainMetadata#914759, commitInfo#914760]
Condition : isnotnull(add#914752)
(3) Project [codegen id : 1]
Output [11]: [add#914752.path AS path#914804, add#914752.partitionValues AS partitionValues#914805, add#914752.size AS size#914806L, add#914752.modificationTime AS modificationTime#914807L, add#914752.dataChange AS dataChange#914808, add#914752.stats AS stats#914809, add#914752.tags AS tags#914810, add#914752.deletionVector AS deletionVector#914811, add#914752.baseRowId AS baseRowId#914812L, add#914752.defaultRowCommitVersion AS defaultRowCommitVersion#914813L, add#914752.clusteringProvider AS clusteringProvider#914814]
Input [10]: [txn#914751, add#914752, remove#914753, metaData#914754, protocol#914755, cdc#914756, checkpointMetadata#914757, sidecar#914758, domainMetadata#914759, commitInfo#914760]