== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#221, add#222, remove#223, metaData#224, protocol#225, cdc#226, checkpointMetadata#227, sidecar#228, domainMetadata#229, commitInfo#230]
Arguments: [txn#221, add#222, remove#223, metaData#224, protocol#225, cdc#226, checkpointMetadata#227, sidecar#228, domainMetadata#229, commitInfo#230], MapPartitionsRDD[8] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#221, add#222, remove#223, metaData#224, protocol#225, cdc#226, checkpointMetadata#227, sidecar#228, domainMetadata#229, commitInfo#230]
Condition : isnotnull(add#222)
(3) Project [codegen id : 1]
Output [11]: [add#222.path AS path#274, add#222.partitionValues AS partitionValues#275, add#222.size AS size#276L, add#222.modificationTime AS modificationTime#277L, add#222.dataChange AS dataChange#278, add#222.stats AS stats#279, add#222.tags AS tags#280, add#222.deletionVector AS deletionVector#281, add#222.baseRowId AS baseRowId#282L, add#222.defaultRowCommitVersion AS defaultRowCommitVersion#283L, add#222.clusteringProvider AS clusteringProvider#284]
Input [10]: [txn#221, add#222, remove#223, metaData#224, protocol#225, cdc#226, checkpointMetadata#227, sidecar#228, domainMetadata#229, commitInfo#230]