== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#8635, add#8636, remove#8637, metaData#8638, protocol#8639, cdc#8640, checkpointMetadata#8641, sidecar#8642, domainMetadata#8643, commitInfo#8644]
Arguments: [txn#8635, add#8636, remove#8637, metaData#8638, protocol#8639, cdc#8640, checkpointMetadata#8641, sidecar#8642, domainMetadata#8643, commitInfo#8644], MapPartitionsRDD[852] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#8635, add#8636, remove#8637, metaData#8638, protocol#8639, cdc#8640, checkpointMetadata#8641, sidecar#8642, domainMetadata#8643, commitInfo#8644]
Condition : isnotnull(add#8636)
(3) Project [codegen id : 1]
Output [11]: [add#8636.path AS path#8688, add#8636.partitionValues AS partitionValues#8689, add#8636.size AS size#8690L, add#8636.modificationTime AS modificationTime#8691L, add#8636.dataChange AS dataChange#8692, null AS stats#8699, add#8636.tags AS tags#8694, add#8636.deletionVector AS deletionVector#8695, add#8636.baseRowId AS baseRowId#8696L, add#8636.defaultRowCommitVersion AS defaultRowCommitVersion#8697L, add#8636.clusteringProvider AS clusteringProvider#8698]
Input [10]: [txn#8635, add#8636, remove#8637, metaData#8638, protocol#8639, cdc#8640, checkpointMetadata#8641, sidecar#8642, domainMetadata#8643, commitInfo#8644]