== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#7670, add#7671, remove#7672, metaData#7673, protocol#7674, cdc#7675, checkpointMetadata#7676, sidecar#7677, domainMetadata#7678, commitInfo#7679]
Arguments: [txn#7670, add#7671, remove#7672, metaData#7673, protocol#7674, cdc#7675, checkpointMetadata#7676, sidecar#7677, domainMetadata#7678, commitInfo#7679], MapPartitionsRDD[750] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#7670, add#7671, remove#7672, metaData#7673, protocol#7674, cdc#7675, checkpointMetadata#7676, sidecar#7677, domainMetadata#7678, commitInfo#7679]
Condition : isnotnull(add#7671)
(3) Project [codegen id : 1]
Output [11]: [add#7671.path AS path#7723, add#7671.partitionValues AS partitionValues#7724, add#7671.size AS size#7725L, add#7671.modificationTime AS modificationTime#7726L, add#7671.dataChange AS dataChange#7727, add#7671.stats AS stats#7728, add#7671.tags AS tags#7729, add#7671.deletionVector AS deletionVector#7730, add#7671.baseRowId AS baseRowId#7731L, add#7671.defaultRowCommitVersion AS defaultRowCommitVersion#7732L, add#7671.clusteringProvider AS clusteringProvider#7733]
Input [10]: [txn#7670, add#7671, remove#7672, metaData#7673, protocol#7674, cdc#7675, checkpointMetadata#7676, sidecar#7677, domainMetadata#7678, commitInfo#7679]