== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1208368, add#1208369, remove#1208370, metaData#1208371, protocol#1208372, cdc#1208373, checkpointMetadata#1208374, sidecar#1208375, domainMetadata#1208376, commitInfo#1208377]
Arguments: [txn#1208368, add#1208369, remove#1208370, metaData#1208371, protocol#1208372, cdc#1208373, checkpointMetadata#1208374, sidecar#1208375, domainMetadata#1208376, commitInfo#1208377], MapPartitionsRDD[69451] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1208368, add#1208369, remove#1208370, metaData#1208371, protocol#1208372, cdc#1208373, checkpointMetadata#1208374, sidecar#1208375, domainMetadata#1208376, commitInfo#1208377]
Condition : isnotnull(add#1208369)
(3) Project [codegen id : 1]
Output [11]: [add#1208369.path AS path#1208421, add#1208369.partitionValues AS partitionValues#1208422, add#1208369.size AS size#1208423L, add#1208369.modificationTime AS modificationTime#1208424L, add#1208369.dataChange AS dataChange#1208425, add#1208369.stats AS stats#1208426, add#1208369.tags AS tags#1208427, add#1208369.deletionVector AS deletionVector#1208428, add#1208369.baseRowId AS baseRowId#1208429L, add#1208369.defaultRowCommitVersion AS defaultRowCommitVersion#1208430L, add#1208369.clusteringProvider AS clusteringProvider#1208431]
Input [10]: [txn#1208368, add#1208369, remove#1208370, metaData#1208371, protocol#1208372, cdc#1208373, checkpointMetadata#1208374, sidecar#1208375, domainMetadata#1208376, commitInfo#1208377]