== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13791099, add#13791100, remove#13791101, metaData#13791102, protocol#13791103, cdc#13791104, checkpointMetadata#13791105, sidecar#13791106, domainMetadata#13791107, commitInfo#13791108]
Arguments: [txn#13791099, add#13791100, remove#13791101, metaData#13791102, protocol#13791103, cdc#13791104, checkpointMetadata#13791105, sidecar#13791106, domainMetadata#13791107, commitInfo#13791108], MapPartitionsRDD[789133] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13791099, add#13791100, remove#13791101, metaData#13791102, protocol#13791103, cdc#13791104, checkpointMetadata#13791105, sidecar#13791106, domainMetadata#13791107, commitInfo#13791108]
Condition : isnotnull(add#13791100)
(3) Project [codegen id : 1]
Output [11]: [add#13791100.path AS path#13791152, add#13791100.partitionValues AS partitionValues#13791153, add#13791100.size AS size#13791154L, add#13791100.modificationTime AS modificationTime#13791155L, add#13791100.dataChange AS dataChange#13791156, add#13791100.stats AS stats#13791157, add#13791100.tags AS tags#13791158, add#13791100.deletionVector AS deletionVector#13791159, add#13791100.baseRowId AS baseRowId#13791160L, add#13791100.defaultRowCommitVersion AS defaultRowCommitVersion#13791161L, add#13791100.clusteringProvider AS clusteringProvider#13791162]
Input [10]: [txn#13791099, add#13791100, remove#13791101, metaData#13791102, protocol#13791103, cdc#13791104, checkpointMetadata#13791105, sidecar#13791106, domainMetadata#13791107, commitInfo#13791108]