== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#5544, add#5545, remove#5546, metaData#5547, protocol#5548, cdc#5549, checkpointMetadata#5550, sidecar#5551, domainMetadata#5552, commitInfo#5553]
Arguments: [txn#5544, add#5545, remove#5546, metaData#5547, protocol#5548, cdc#5549, checkpointMetadata#5550, sidecar#5551, domainMetadata#5552, commitInfo#5553], MapPartitionsRDD[538] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#5544, add#5545, remove#5546, metaData#5547, protocol#5548, cdc#5549, checkpointMetadata#5550, sidecar#5551, domainMetadata#5552, commitInfo#5553]
Condition : isnotnull(add#5545)
(3) Project [codegen id : 1]
Output [11]: [add#5545.path AS path#5597, add#5545.partitionValues AS partitionValues#5598, add#5545.size AS size#5599L, add#5545.modificationTime AS modificationTime#5600L, add#5545.dataChange AS dataChange#5601, add#5545.stats AS stats#5602, add#5545.tags AS tags#5603, add#5545.deletionVector AS deletionVector#5604, add#5545.baseRowId AS baseRowId#5605L, add#5545.defaultRowCommitVersion AS defaultRowCommitVersion#5606L, add#5545.clusteringProvider AS clusteringProvider#5607]
Input [10]: [txn#5544, add#5545, remove#5546, metaData#5547, protocol#5548, cdc#5549, checkpointMetadata#5550, sidecar#5551, domainMetadata#5552, commitInfo#5553]