== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#7572, add#7573, remove#7574, metaData#7575, protocol#7576, cdc#7577, checkpointMetadata#7578, sidecar#7579, domainMetadata#7580, commitInfo#7581]
Arguments: [txn#7572, add#7573, remove#7574, metaData#7575, protocol#7576, cdc#7577, checkpointMetadata#7578, sidecar#7579, domainMetadata#7580, commitInfo#7581], MapPartitionsRDD[746] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#7572, add#7573, remove#7574, metaData#7575, protocol#7576, cdc#7577, checkpointMetadata#7578, sidecar#7579, domainMetadata#7580, commitInfo#7581]
Condition : isnotnull(add#7573)
(3) Project [codegen id : 1]
Output [11]: [add#7573.path AS path#7625, add#7573.partitionValues AS partitionValues#7626, add#7573.size AS size#7627L, add#7573.modificationTime AS modificationTime#7628L, add#7573.dataChange AS dataChange#7629, null AS stats#7636, add#7573.tags AS tags#7631, add#7573.deletionVector AS deletionVector#7632, add#7573.baseRowId AS baseRowId#7633L, add#7573.defaultRowCommitVersion AS defaultRowCommitVersion#7634L, add#7573.clusteringProvider AS clusteringProvider#7635]
Input [10]: [txn#7572, add#7573, remove#7574, metaData#7575, protocol#7576, cdc#7577, checkpointMetadata#7578, sidecar#7579, domainMetadata#7580, commitInfo#7581]