== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#21517004, add#21517005, remove#21517006, metaData#21517007, protocol#21517008, cdc#21517009, checkpointMetadata#21517010, sidecar#21517011, domainMetadata#21517012, commitInfo#21517013]
Arguments: [txn#21517004, add#21517005, remove#21517006, metaData#21517007, protocol#21517008, cdc#21517009, checkpointMetadata#21517010, sidecar#21517011, domainMetadata#21517012, commitInfo#21517013], MapPartitionsRDD[1241213] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#21517004, add#21517005, remove#21517006, metaData#21517007, protocol#21517008, cdc#21517009, checkpointMetadata#21517010, sidecar#21517011, domainMetadata#21517012, commitInfo#21517013]
Condition : isnotnull(add#21517005)
(3) Project [codegen id : 1]
Output [11]: [add#21517005.path AS path#21517057, add#21517005.partitionValues AS partitionValues#21517058, add#21517005.size AS size#21517059L, add#21517005.modificationTime AS modificationTime#21517060L, add#21517005.dataChange AS dataChange#21517061, null AS stats#21517068, add#21517005.tags AS tags#21517063, add#21517005.deletionVector AS deletionVector#21517064, add#21517005.baseRowId AS baseRowId#21517065L, add#21517005.defaultRowCommitVersion AS defaultRowCommitVersion#21517066L, add#21517005.clusteringProvider AS clusteringProvider#21517067]
Input [10]: [txn#21517004, add#21517005, remove#21517006, metaData#21517007, protocol#21517008, cdc#21517009, checkpointMetadata#21517010, sidecar#21517011, domainMetadata#21517012, commitInfo#21517013]