== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#25643, add#25644, remove#25645, metaData#25646, protocol#25647, cdc#25648, checkpointMetadata#25649, sidecar#25650, domainMetadata#25651, commitInfo#25652]
Arguments: [txn#25643, add#25644, remove#25645, metaData#25646, protocol#25647, cdc#25648, checkpointMetadata#25649, sidecar#25650, domainMetadata#25651, commitInfo#25652], MapPartitionsRDD[2548] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#25643, add#25644, remove#25645, metaData#25646, protocol#25647, cdc#25648, checkpointMetadata#25649, sidecar#25650, domainMetadata#25651, commitInfo#25652]
Condition : isnotnull(add#25644)
(3) Project [codegen id : 1]
Output [11]: [add#25644.path AS path#25696, add#25644.partitionValues AS partitionValues#25697, add#25644.size AS size#25698L, add#25644.modificationTime AS modificationTime#25699L, add#25644.dataChange AS dataChange#25700, null AS stats#25707, add#25644.tags AS tags#25702, add#25644.deletionVector AS deletionVector#25703, add#25644.baseRowId AS baseRowId#25704L, add#25644.defaultRowCommitVersion AS defaultRowCommitVersion#25705L, add#25644.clusteringProvider AS clusteringProvider#25706]
Input [10]: [txn#25643, add#25644, remove#25645, metaData#25646, protocol#25647, cdc#25648, checkpointMetadata#25649, sidecar#25650, domainMetadata#25651, commitInfo#25652]