== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#152322, add#152323, remove#152324, metaData#152325, protocol#152326, cdc#152327, checkpointMetadata#152328, sidecar#152329, domainMetadata#152330, commitInfo#152331]
Arguments: [txn#152322, add#152323, remove#152324, metaData#152325, protocol#152326, cdc#152327, checkpointMetadata#152328, sidecar#152329, domainMetadata#152330, commitInfo#152331], MapPartitionsRDD[8795] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#152322, add#152323, remove#152324, metaData#152325, protocol#152326, cdc#152327, checkpointMetadata#152328, sidecar#152329, domainMetadata#152330, commitInfo#152331]
Condition : isnotnull(add#152323)
(3) Project [codegen id : 1]
Output [11]: [add#152323.path AS path#152375, add#152323.partitionValues AS partitionValues#152376, add#152323.size AS size#152377L, add#152323.modificationTime AS modificationTime#152378L, add#152323.dataChange AS dataChange#152379, add#152323.stats AS stats#152380, add#152323.tags AS tags#152381, add#152323.deletionVector AS deletionVector#152382, add#152323.baseRowId AS baseRowId#152383L, add#152323.defaultRowCommitVersion AS defaultRowCommitVersion#152384L, add#152323.clusteringProvider AS clusteringProvider#152385]
Input [10]: [txn#152322, add#152323, remove#152324, metaData#152325, protocol#152326, cdc#152327, checkpointMetadata#152328, sidecar#152329, domainMetadata#152330, commitInfo#152331]