== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#957664, add#957665, remove#957666, metaData#957667, protocol#957668, cdc#957669, checkpointMetadata#957670, sidecar#957671, domainMetadata#957672, commitInfo#957673]
Arguments: [txn#957664, add#957665, remove#957666, metaData#957667, protocol#957668, cdc#957669, checkpointMetadata#957670, sidecar#957671, domainMetadata#957672, commitInfo#957673], MapPartitionsRDD[47644] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#957664, add#957665, remove#957666, metaData#957667, protocol#957668, cdc#957669, checkpointMetadata#957670, sidecar#957671, domainMetadata#957672, commitInfo#957673]
Condition : isnotnull(add#957665)
(3) Project [codegen id : 1]
Output [11]: [add#957665.path AS path#957717, add#957665.partitionValues AS partitionValues#957718, add#957665.size AS size#957719L, add#957665.modificationTime AS modificationTime#957720L, add#957665.dataChange AS dataChange#957721, add#957665.stats AS stats#957722, add#957665.tags AS tags#957723, add#957665.deletionVector AS deletionVector#957724, add#957665.baseRowId AS baseRowId#957725L, add#957665.defaultRowCommitVersion AS defaultRowCommitVersion#957726L, add#957665.clusteringProvider AS clusteringProvider#957727]
Input [10]: [txn#957664, add#957665, remove#957666, metaData#957667, protocol#957668, cdc#957669, checkpointMetadata#957670, sidecar#957671, domainMetadata#957672, commitInfo#957673]