== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#999668, add#999669, remove#999670, metaData#999671, protocol#999672, cdc#999673, checkpointMetadata#999674, sidecar#999675, domainMetadata#999676, commitInfo#999677]
Arguments: [txn#999668, add#999669, remove#999670, metaData#999671, protocol#999672, cdc#999673, checkpointMetadata#999674, sidecar#999675, domainMetadata#999676, commitInfo#999677], MapPartitionsRDD[46778] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#999668, add#999669, remove#999670, metaData#999671, protocol#999672, cdc#999673, checkpointMetadata#999674, sidecar#999675, domainMetadata#999676, commitInfo#999677]
Condition : isnotnull(add#999669)
(3) Project [codegen id : 1]
Output [11]: [add#999669.path AS path#999721, add#999669.partitionValues AS partitionValues#999722, add#999669.size AS size#999723L, add#999669.modificationTime AS modificationTime#999724L, add#999669.dataChange AS dataChange#999725, null AS stats#999732, add#999669.tags AS tags#999727, add#999669.deletionVector AS deletionVector#999728, add#999669.baseRowId AS baseRowId#999729L, add#999669.defaultRowCommitVersion AS defaultRowCommitVersion#999730L, add#999669.clusteringProvider AS clusteringProvider#999731]
Input [10]: [txn#999668, add#999669, remove#999670, metaData#999671, protocol#999672, cdc#999673, checkpointMetadata#999674, sidecar#999675, domainMetadata#999676, commitInfo#999677]