== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#6607, add#6608, remove#6609, metaData#6610, protocol#6611, cdc#6612, checkpointMetadata#6613, sidecar#6614, domainMetadata#6615, commitInfo#6616]
Arguments: [txn#6607, add#6608, remove#6609, metaData#6610, protocol#6611, cdc#6612, checkpointMetadata#6613, sidecar#6614, domainMetadata#6615, commitInfo#6616], MapPartitionsRDD[644] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#6607, add#6608, remove#6609, metaData#6610, protocol#6611, cdc#6612, checkpointMetadata#6613, sidecar#6614, domainMetadata#6615, commitInfo#6616]
Condition : isnotnull(add#6608)
(3) Project [codegen id : 1]
Output [11]: [add#6608.path AS path#6660, add#6608.partitionValues AS partitionValues#6661, add#6608.size AS size#6662L, add#6608.modificationTime AS modificationTime#6663L, add#6608.dataChange AS dataChange#6664, add#6608.stats AS stats#6665, add#6608.tags AS tags#6666, add#6608.deletionVector AS deletionVector#6667, add#6608.baseRowId AS baseRowId#6668L, add#6608.defaultRowCommitVersion AS defaultRowCommitVersion#6669L, add#6608.clusteringProvider AS clusteringProvider#6670]
Input [10]: [txn#6607, add#6608, remove#6609, metaData#6610, protocol#6611, cdc#6612, checkpointMetadata#6613, sidecar#6614, domainMetadata#6615, commitInfo#6616]