== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#26706, add#26707, remove#26708, metaData#26709, protocol#26710, cdc#26711, checkpointMetadata#26712, sidecar#26713, domainMetadata#26714, commitInfo#26715]
Arguments: [txn#26706, add#26707, remove#26708, metaData#26709, protocol#26710, cdc#26711, checkpointMetadata#26712, sidecar#26713, domainMetadata#26714, commitInfo#26715], MapPartitionsRDD[2654] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#26706, add#26707, remove#26708, metaData#26709, protocol#26710, cdc#26711, checkpointMetadata#26712, sidecar#26713, domainMetadata#26714, commitInfo#26715]
Condition : isnotnull(add#26707)
(3) Project [codegen id : 1]
Output [11]: [add#26707.path AS path#26759, add#26707.partitionValues AS partitionValues#26760, add#26707.size AS size#26761L, add#26707.modificationTime AS modificationTime#26762L, add#26707.dataChange AS dataChange#26763, null AS stats#26770, add#26707.tags AS tags#26765, add#26707.deletionVector AS deletionVector#26766, add#26707.baseRowId AS baseRowId#26767L, add#26707.defaultRowCommitVersion AS defaultRowCommitVersion#26768L, add#26707.clusteringProvider AS clusteringProvider#26769]
Input [10]: [txn#26706, add#26707, remove#26708, metaData#26709, protocol#26710, cdc#26711, checkpointMetadata#26712, sidecar#26713, domainMetadata#26714, commitInfo#26715]