== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#49574, add#49575, remove#49576, metaData#49577, protocol#49578, cdc#49579, checkpointMetadata#49580, sidecar#49581, domainMetadata#49582, commitInfo#49583]
Arguments: [txn#49574, add#49575, remove#49576, metaData#49577, protocol#49578, cdc#49579, checkpointMetadata#49580, sidecar#49581, domainMetadata#49582, commitInfo#49583], MapPartitionsRDD[2554] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#49574, add#49575, remove#49576, metaData#49577, protocol#49578, cdc#49579, checkpointMetadata#49580, sidecar#49581, domainMetadata#49582, commitInfo#49583]
Condition : isnotnull(add#49575)
(3) Project [codegen id : 1]
Output [11]: [add#49575.path AS path#49627, add#49575.partitionValues AS partitionValues#49628, add#49575.size AS size#49629L, add#49575.modificationTime AS modificationTime#49630L, add#49575.dataChange AS dataChange#49631, null AS stats#49638, add#49575.tags AS tags#49633, add#49575.deletionVector AS deletionVector#49634, add#49575.baseRowId AS baseRowId#49635L, add#49575.defaultRowCommitVersion AS defaultRowCommitVersion#49636L, add#49575.clusteringProvider AS clusteringProvider#49637]
Input [10]: [txn#49574, add#49575, remove#49576, metaData#49577, protocol#49578, cdc#49579, checkpointMetadata#49580, sidecar#49581, domainMetadata#49582, commitInfo#49583]