== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#88042, add#88043, remove#88044, metaData#88045, protocol#88046, cdc#88047, checkpointMetadata#88048, sidecar#88049, domainMetadata#88050, commitInfo#88051]
Arguments: [txn#88042, add#88043, remove#88044, metaData#88045, protocol#88046, cdc#88047, checkpointMetadata#88048, sidecar#88049, domainMetadata#88050, commitInfo#88051], MapPartitionsRDD[5063] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#88042, add#88043, remove#88044, metaData#88045, protocol#88046, cdc#88047, checkpointMetadata#88048, sidecar#88049, domainMetadata#88050, commitInfo#88051]
Condition : isnotnull(add#88043)
(3) Project [codegen id : 1]
Output [11]: [add#88043.path AS path#88095, add#88043.partitionValues AS partitionValues#88096, add#88043.size AS size#88097L, add#88043.modificationTime AS modificationTime#88098L, add#88043.dataChange AS dataChange#88099, add#88043.stats AS stats#88100, add#88043.tags AS tags#88101, add#88043.deletionVector AS deletionVector#88102, add#88043.baseRowId AS baseRowId#88103L, add#88043.defaultRowCommitVersion AS defaultRowCommitVersion#88104L, add#88043.clusteringProvider AS clusteringProvider#88105]
Input [10]: [txn#88042, add#88043, remove#88044, metaData#88045, protocol#88046, cdc#88047, checkpointMetadata#88048, sidecar#88049, domainMetadata#88050, commitInfo#88051]