== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#67029, add#67030, remove#67031, metaData#67032, protocol#67033, cdc#67034, checkpointMetadata#67035, sidecar#67036, domainMetadata#67037, commitInfo#67038]
Arguments: [txn#67029, add#67030, remove#67031, metaData#67032, protocol#67033, cdc#67034, checkpointMetadata#67035, sidecar#67036, domainMetadata#67037, commitInfo#67038], MapPartitionsRDD[3920] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#67029, add#67030, remove#67031, metaData#67032, protocol#67033, cdc#67034, checkpointMetadata#67035, sidecar#67036, domainMetadata#67037, commitInfo#67038]
Condition : isnotnull(add#67030)
(3) Project [codegen id : 1]
Output [11]: [add#67030.path AS path#67082, add#67030.partitionValues AS partitionValues#67083, add#67030.size AS size#67084L, add#67030.modificationTime AS modificationTime#67085L, add#67030.dataChange AS dataChange#67086, add#67030.stats AS stats#67087, add#67030.tags AS tags#67088, add#67030.deletionVector AS deletionVector#67089, add#67030.baseRowId AS baseRowId#67090L, add#67030.defaultRowCommitVersion AS defaultRowCommitVersion#67091L, add#67030.clusteringProvider AS clusteringProvider#67092]
Input [10]: [txn#67029, add#67030, remove#67031, metaData#67032, protocol#67033, cdc#67034, checkpointMetadata#67035, sidecar#67036, domainMetadata#67037, commitInfo#67038]