== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#25038, add#25039, remove#25040, metaData#25041, protocol#25042, cdc#25043, checkpointMetadata#25044, sidecar#25045, domainMetadata#25046, commitInfo#25047]
Arguments: [txn#25038, add#25039, remove#25040, metaData#25041, protocol#25042, cdc#25043, checkpointMetadata#25044, sidecar#25045, domainMetadata#25046, commitInfo#25047], MapPartitionsRDD[1283] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#25038, add#25039, remove#25040, metaData#25041, protocol#25042, cdc#25043, checkpointMetadata#25044, sidecar#25045, domainMetadata#25046, commitInfo#25047]
Condition : isnotnull(add#25039)
(3) Project [codegen id : 1]
Output [11]: [add#25039.path AS path#25091, add#25039.partitionValues AS partitionValues#25092, add#25039.size AS size#25093L, add#25039.modificationTime AS modificationTime#25094L, add#25039.dataChange AS dataChange#25095, add#25039.stats AS stats#25096, add#25039.tags AS tags#25097, add#25039.deletionVector AS deletionVector#25098, add#25039.baseRowId AS baseRowId#25099L, add#25039.defaultRowCommitVersion AS defaultRowCommitVersion#25100L, add#25039.clusteringProvider AS clusteringProvider#25101]
Input [10]: [txn#25038, add#25039, remove#25040, metaData#25041, protocol#25042, cdc#25043, checkpointMetadata#25044, sidecar#25045, domainMetadata#25046, commitInfo#25047]