== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#999766, add#999767, remove#999768, metaData#999769, protocol#999770, cdc#999771, checkpointMetadata#999772, sidecar#999773, domainMetadata#999774, commitInfo#999775]
Arguments: [txn#999766, add#999767, remove#999768, metaData#999769, protocol#999770, cdc#999771, checkpointMetadata#999772, sidecar#999773, domainMetadata#999774, commitInfo#999775], MapPartitionsRDD[46782] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#999766, add#999767, remove#999768, metaData#999769, protocol#999770, cdc#999771, checkpointMetadata#999772, sidecar#999773, domainMetadata#999774, commitInfo#999775]
Condition : isnotnull(add#999767)
(3) Project [codegen id : 1]
Output [11]: [add#999767.path AS path#999819, add#999767.partitionValues AS partitionValues#999820, add#999767.size AS size#999821L, add#999767.modificationTime AS modificationTime#999822L, add#999767.dataChange AS dataChange#999823, add#999767.stats AS stats#999824, add#999767.tags AS tags#999825, add#999767.deletionVector AS deletionVector#999826, add#999767.baseRowId AS baseRowId#999827L, add#999767.defaultRowCommitVersion AS defaultRowCommitVersion#999828L, add#999767.clusteringProvider AS clusteringProvider#999829]
Input [10]: [txn#999766, add#999767, remove#999768, metaData#999769, protocol#999770, cdc#999771, checkpointMetadata#999772, sidecar#999773, domainMetadata#999774, commitInfo#999775]