== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#8733, add#8734, remove#8735, metaData#8736, protocol#8737, cdc#8738, checkpointMetadata#8739, sidecar#8740, domainMetadata#8741, commitInfo#8742]
Arguments: [txn#8733, add#8734, remove#8735, metaData#8736, protocol#8737, cdc#8738, checkpointMetadata#8739, sidecar#8740, domainMetadata#8741, commitInfo#8742], MapPartitionsRDD[856] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#8733, add#8734, remove#8735, metaData#8736, protocol#8737, cdc#8738, checkpointMetadata#8739, sidecar#8740, domainMetadata#8741, commitInfo#8742]
Condition : isnotnull(add#8734)
(3) Project [codegen id : 1]
Output [11]: [add#8734.path AS path#8786, add#8734.partitionValues AS partitionValues#8787, add#8734.size AS size#8788L, add#8734.modificationTime AS modificationTime#8789L, add#8734.dataChange AS dataChange#8790, add#8734.stats AS stats#8791, add#8734.tags AS tags#8792, add#8734.deletionVector AS deletionVector#8793, add#8734.baseRowId AS baseRowId#8794L, add#8734.defaultRowCommitVersion AS defaultRowCommitVersion#8795L, add#8734.clusteringProvider AS clusteringProvider#8796]
Input [10]: [txn#8733, add#8734, remove#8735, metaData#8736, protocol#8737, cdc#8738, checkpointMetadata#8739, sidecar#8740, domainMetadata#8741, commitInfo#8742]