== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#731071, add#731072, remove#731073, metaData#731074, protocol#731075, cdc#731076, checkpointMetadata#731077, sidecar#731078, domainMetadata#731079, commitInfo#731080]
Arguments: [txn#731071, add#731072, remove#731073, metaData#731074, protocol#731075, cdc#731076, checkpointMetadata#731077, sidecar#731078, domainMetadata#731079, commitInfo#731080], MapPartitionsRDD[34365] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#731071, add#731072, remove#731073, metaData#731074, protocol#731075, cdc#731076, checkpointMetadata#731077, sidecar#731078, domainMetadata#731079, commitInfo#731080]
Condition : isnotnull(add#731072)
(3) Project [codegen id : 1]
Output [11]: [add#731072.path AS path#731124, add#731072.partitionValues AS partitionValues#731125, add#731072.size AS size#731126L, add#731072.modificationTime AS modificationTime#731127L, add#731072.dataChange AS dataChange#731128, add#731072.stats AS stats#731129, add#731072.tags AS tags#731130, add#731072.deletionVector AS deletionVector#731131, add#731072.baseRowId AS baseRowId#731132L, add#731072.defaultRowCommitVersion AS defaultRowCommitVersion#731133L, add#731072.clusteringProvider AS clusteringProvider#731134]
Input [10]: [txn#731071, add#731072, remove#731073, metaData#731074, protocol#731075, cdc#731076, checkpointMetadata#731077, sidecar#731078, domainMetadata#731079, commitInfo#731080]