== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#127, add#128, remove#129, metaData#130, protocol#131, cdc#132, checkpointMetadata#133, sidecar#134, domainMetadata#135, commitInfo#136]
Arguments: [txn#127, add#128, remove#129, metaData#130, protocol#131, cdc#132, checkpointMetadata#133, sidecar#134, domainMetadata#135, commitInfo#136], MapPartitionsRDD[9] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#127, add#128, remove#129, metaData#130, protocol#131, cdc#132, checkpointMetadata#133, sidecar#134, domainMetadata#135, commitInfo#136]
Condition : isnotnull(add#128)
(3) Project [codegen id : 1]
Output [11]: [add#128.path AS path#201, add#128.partitionValues AS partitionValues#202, add#128.size AS size#203L, add#128.modificationTime AS modificationTime#204L, add#128.dataChange AS dataChange#205, null AS stats#212, add#128.tags AS tags#207, add#128.deletionVector AS deletionVector#208, add#128.baseRowId AS baseRowId#209L, add#128.defaultRowCommitVersion AS defaultRowCommitVersion#210L, add#128.clusteringProvider AS clusteringProvider#211]
Input [10]: [txn#127, add#128, remove#129, metaData#130, protocol#131, cdc#132, checkpointMetadata#133, sidecar#134, domainMetadata#135, commitInfo#136]