== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#24940, add#24941, remove#24942, metaData#24943, protocol#24944, cdc#24945, checkpointMetadata#24946, sidecar#24947, domainMetadata#24948, commitInfo#24949]
Arguments: [txn#24940, add#24941, remove#24942, metaData#24943, protocol#24944, cdc#24945, checkpointMetadata#24946, sidecar#24947, domainMetadata#24948, commitInfo#24949], MapPartitionsRDD[1279] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#24940, add#24941, remove#24942, metaData#24943, protocol#24944, cdc#24945, checkpointMetadata#24946, sidecar#24947, domainMetadata#24948, commitInfo#24949]
Condition : isnotnull(add#24941)
(3) Project [codegen id : 1]
Output [11]: [add#24941.path AS path#24993, add#24941.partitionValues AS partitionValues#24994, add#24941.size AS size#24995L, add#24941.modificationTime AS modificationTime#24996L, add#24941.dataChange AS dataChange#24997, null AS stats#25004, add#24941.tags AS tags#24999, add#24941.deletionVector AS deletionVector#25000, add#24941.baseRowId AS baseRowId#25001L, add#24941.defaultRowCommitVersion AS defaultRowCommitVersion#25002L, add#24941.clusteringProvider AS clusteringProvider#25003]
Input [10]: [txn#24940, add#24941, remove#24942, metaData#24943, protocol#24944, cdc#24945, checkpointMetadata#24946, sidecar#24947, domainMetadata#24948, commitInfo#24949]