== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#943432, add#943433, remove#943434, metaData#943435, protocol#943436, cdc#943437, checkpointMetadata#943438, sidecar#943439, domainMetadata#943440, commitInfo#943441]
Arguments: [txn#943432, add#943433, remove#943434, metaData#943435, protocol#943436, cdc#943437, checkpointMetadata#943438, sidecar#943439, domainMetadata#943440, commitInfo#943441], MapPartitionsRDD[46880] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#943432, add#943433, remove#943434, metaData#943435, protocol#943436, cdc#943437, checkpointMetadata#943438, sidecar#943439, domainMetadata#943440, commitInfo#943441]
Condition : isnotnull(add#943433)
(3) Project [codegen id : 1]
Output [11]: [add#943433.path AS path#943485, add#943433.partitionValues AS partitionValues#943486, add#943433.size AS size#943487L, add#943433.modificationTime AS modificationTime#943488L, add#943433.dataChange AS dataChange#943489, add#943433.stats AS stats#943490, add#943433.tags AS tags#943491, add#943433.deletionVector AS deletionVector#943492, add#943433.baseRowId AS baseRowId#943493L, add#943433.defaultRowCommitVersion AS defaultRowCommitVersion#943494L, add#943433.clusteringProvider AS clusteringProvider#943495]
Input [10]: [txn#943432, add#943433, remove#943434, metaData#943435, protocol#943436, cdc#943437, checkpointMetadata#943438, sidecar#943439, domainMetadata#943440, commitInfo#943441]