== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#9698, add#9699, remove#9700, metaData#9701, protocol#9702, cdc#9703, checkpointMetadata#9704, sidecar#9705, domainMetadata#9706, commitInfo#9707]
Arguments: [txn#9698, add#9699, remove#9700, metaData#9701, protocol#9702, cdc#9703, checkpointMetadata#9704, sidecar#9705, domainMetadata#9706, commitInfo#9707], MapPartitionsRDD[958] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#9698, add#9699, remove#9700, metaData#9701, protocol#9702, cdc#9703, checkpointMetadata#9704, sidecar#9705, domainMetadata#9706, commitInfo#9707]
Condition : isnotnull(add#9699)
(3) Project [codegen id : 1]
Output [11]: [add#9699.path AS path#9751, add#9699.partitionValues AS partitionValues#9752, add#9699.size AS size#9753L, add#9699.modificationTime AS modificationTime#9754L, add#9699.dataChange AS dataChange#9755, null AS stats#9762, add#9699.tags AS tags#9757, add#9699.deletionVector AS deletionVector#9758, add#9699.baseRowId AS baseRowId#9759L, add#9699.defaultRowCommitVersion AS defaultRowCommitVersion#9760L, add#9699.clusteringProvider AS clusteringProvider#9761]
Input [10]: [txn#9698, add#9699, remove#9700, metaData#9701, protocol#9702, cdc#9703, checkpointMetadata#9704, sidecar#9705, domainMetadata#9706, commitInfo#9707]