== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#904515, add#904516, remove#904517, metaData#904518, protocol#904519, cdc#904520, checkpointMetadata#904521, sidecar#904522, domainMetadata#904523, commitInfo#904524]
Arguments: [txn#904515, add#904516, remove#904517, metaData#904518, protocol#904519, cdc#904520, checkpointMetadata#904521, sidecar#904522, domainMetadata#904523, commitInfo#904524], MapPartitionsRDD[44973] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#904515, add#904516, remove#904517, metaData#904518, protocol#904519, cdc#904520, checkpointMetadata#904521, sidecar#904522, domainMetadata#904523, commitInfo#904524]
Condition : isnotnull(add#904516)
(3) Project [codegen id : 1]
Output [11]: [add#904516.path AS path#904568, add#904516.partitionValues AS partitionValues#904569, add#904516.size AS size#904570L, add#904516.modificationTime AS modificationTime#904571L, add#904516.dataChange AS dataChange#904572, add#904516.stats AS stats#904573, add#904516.tags AS tags#904574, add#904516.deletionVector AS deletionVector#904575, add#904516.baseRowId AS baseRowId#904576L, add#904516.defaultRowCommitVersion AS defaultRowCommitVersion#904577L, add#904516.clusteringProvider AS clusteringProvider#904578]
Input [10]: [txn#904515, add#904516, remove#904517, metaData#904518, protocol#904519, cdc#904520, checkpointMetadata#904521, sidecar#904522, domainMetadata#904523, commitInfo#904524]