== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#87847, add#87848, remove#87849, metaData#87850, protocol#87851, cdc#87852, checkpointMetadata#87853, sidecar#87854, domainMetadata#87855, commitInfo#87856]
Arguments: [txn#87847, add#87848, remove#87849, metaData#87850, protocol#87851, cdc#87852, checkpointMetadata#87853, sidecar#87854, domainMetadata#87855, commitInfo#87856], MapPartitionsRDD[5055] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#87847, add#87848, remove#87849, metaData#87850, protocol#87851, cdc#87852, checkpointMetadata#87853, sidecar#87854, domainMetadata#87855, commitInfo#87856]
Condition : isnotnull(add#87848)
(3) Project [codegen id : 1]
Output [11]: [add#87848.path AS path#87900, add#87848.partitionValues AS partitionValues#87901, add#87848.size AS size#87902L, add#87848.modificationTime AS modificationTime#87903L, add#87848.dataChange AS dataChange#87904, null AS stats#87911, add#87848.tags AS tags#87906, add#87848.deletionVector AS deletionVector#87907, add#87848.baseRowId AS baseRowId#87908L, add#87848.defaultRowCommitVersion AS defaultRowCommitVersion#87909L, add#87848.clusteringProvider AS clusteringProvider#87910]
Input [10]: [txn#87847, add#87848, remove#87849, metaData#87850, protocol#87851, cdc#87852, checkpointMetadata#87853, sidecar#87854, domainMetadata#87855, commitInfo#87856]