== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1008624, add#1008625, remove#1008626, metaData#1008627, protocol#1008628, cdc#1008629, checkpointMetadata#1008630, sidecar#1008631, domainMetadata#1008632, commitInfo#1008633]
Arguments: [txn#1008624, add#1008625, remove#1008626, metaData#1008627, protocol#1008628, cdc#1008629, checkpointMetadata#1008630, sidecar#1008631, domainMetadata#1008632, commitInfo#1008633], MapPartitionsRDD[47189] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1008624, add#1008625, remove#1008626, metaData#1008627, protocol#1008628, cdc#1008629, checkpointMetadata#1008630, sidecar#1008631, domainMetadata#1008632, commitInfo#1008633]
Condition : isnotnull(add#1008625)
(3) Project [codegen id : 1]
Output [11]: [add#1008625.path AS path#1008677, add#1008625.partitionValues AS partitionValues#1008678, add#1008625.size AS size#1008679L, add#1008625.modificationTime AS modificationTime#1008680L, add#1008625.dataChange AS dataChange#1008681, add#1008625.stats AS stats#1008682, add#1008625.tags AS tags#1008683, add#1008625.deletionVector AS deletionVector#1008684, add#1008625.baseRowId AS baseRowId#1008685L, add#1008625.defaultRowCommitVersion AS defaultRowCommitVersion#1008686L, add#1008625.clusteringProvider AS clusteringProvider#1008687]
Input [10]: [txn#1008624, add#1008625, remove#1008626, metaData#1008627, protocol#1008628, cdc#1008629, checkpointMetadata#1008630, sidecar#1008631, domainMetadata#1008632, commitInfo#1008633]