== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#17139, add#17140, remove#17141, metaData#17142, protocol#17143, cdc#17144, checkpointMetadata#17145, sidecar#17146, domainMetadata#17147, commitInfo#17148]
Arguments: [txn#17139, add#17140, remove#17141, metaData#17142, protocol#17143, cdc#17144, checkpointMetadata#17145, sidecar#17146, domainMetadata#17147, commitInfo#17148], MapPartitionsRDD[1700] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#17139, add#17140, remove#17141, metaData#17142, protocol#17143, cdc#17144, checkpointMetadata#17145, sidecar#17146, domainMetadata#17147, commitInfo#17148]
Condition : isnotnull(add#17140)
(3) Project [codegen id : 1]
Output [11]: [add#17140.path AS path#17192, add#17140.partitionValues AS partitionValues#17193, add#17140.size AS size#17194L, add#17140.modificationTime AS modificationTime#17195L, add#17140.dataChange AS dataChange#17196, null AS stats#17203, add#17140.tags AS tags#17198, add#17140.deletionVector AS deletionVector#17199, add#17140.baseRowId AS baseRowId#17200L, add#17140.defaultRowCommitVersion AS defaultRowCommitVersion#17201L, add#17140.clusteringProvider AS clusteringProvider#17202]
Input [10]: [txn#17139, add#17140, remove#17141, metaData#17142, protocol#17143, cdc#17144, checkpointMetadata#17145, sidecar#17146, domainMetadata#17147, commitInfo#17148]