== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#920017, add#920018, remove#920019, metaData#920020, protocol#920021, cdc#920022, checkpointMetadata#920023, sidecar#920024, domainMetadata#920025, commitInfo#920026]
Arguments: [txn#920017, add#920018, remove#920019, metaData#920020, protocol#920021, cdc#920022, checkpointMetadata#920023, sidecar#920024, domainMetadata#920025, commitInfo#920026], MapPartitionsRDD[43088] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#920017, add#920018, remove#920019, metaData#920020, protocol#920021, cdc#920022, checkpointMetadata#920023, sidecar#920024, domainMetadata#920025, commitInfo#920026]
Condition : isnotnull(add#920018)
(3) Project [codegen id : 1]
Output [11]: [add#920018.path AS path#920070, add#920018.partitionValues AS partitionValues#920071, add#920018.size AS size#920072L, add#920018.modificationTime AS modificationTime#920073L, add#920018.dataChange AS dataChange#920074, add#920018.stats AS stats#920075, add#920018.tags AS tags#920076, add#920018.deletionVector AS deletionVector#920077, add#920018.baseRowId AS baseRowId#920078L, add#920018.defaultRowCommitVersion AS defaultRowCommitVersion#920079L, add#920018.clusteringProvider AS clusteringProvider#920080]
Input [10]: [txn#920017, add#920018, remove#920019, metaData#920020, protocol#920021, cdc#920022, checkpointMetadata#920023, sidecar#920024, domainMetadata#920025, commitInfo#920026]