== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#15111, add#15112, remove#15113, metaData#15114, protocol#15115, cdc#15116, checkpointMetadata#15117, sidecar#15118, domainMetadata#15119, commitInfo#15120]
Arguments: [txn#15111, add#15112, remove#15113, metaData#15114, protocol#15115, cdc#15116, checkpointMetadata#15117, sidecar#15118, domainMetadata#15119, commitInfo#15120], MapPartitionsRDD[1492] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#15111, add#15112, remove#15113, metaData#15114, protocol#15115, cdc#15116, checkpointMetadata#15117, sidecar#15118, domainMetadata#15119, commitInfo#15120]
Condition : isnotnull(add#15112)
(3) Project [codegen id : 1]
Output [11]: [add#15112.path AS path#15164, add#15112.partitionValues AS partitionValues#15165, add#15112.size AS size#15166L, add#15112.modificationTime AS modificationTime#15167L, add#15112.dataChange AS dataChange#15168, add#15112.stats AS stats#15169, add#15112.tags AS tags#15170, add#15112.deletionVector AS deletionVector#15171, add#15112.baseRowId AS baseRowId#15172L, add#15112.defaultRowCommitVersion AS defaultRowCommitVersion#15173L, add#15112.clusteringProvider AS clusteringProvider#15174]
Input [10]: [txn#15111, add#15112, remove#15113, metaData#15114, protocol#15115, cdc#15116, checkpointMetadata#15117, sidecar#15118, domainMetadata#15119, commitInfo#15120]