== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1224724, add#1224725, remove#1224726, metaData#1224727, protocol#1224728, cdc#1224729, checkpointMetadata#1224730, sidecar#1224731, domainMetadata#1224732, commitInfo#1224733]
Arguments: [txn#1224724, add#1224725, remove#1224726, metaData#1224727, protocol#1224728, cdc#1224729, checkpointMetadata#1224730, sidecar#1224731, domainMetadata#1224732, commitInfo#1224733], MapPartitionsRDD[70424] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1224724, add#1224725, remove#1224726, metaData#1224727, protocol#1224728, cdc#1224729, checkpointMetadata#1224730, sidecar#1224731, domainMetadata#1224732, commitInfo#1224733]
Condition : isnotnull(add#1224725)
(3) Project [codegen id : 1]
Output [11]: [add#1224725.path AS path#1224777, add#1224725.partitionValues AS partitionValues#1224778, add#1224725.size AS size#1224779L, add#1224725.modificationTime AS modificationTime#1224780L, add#1224725.dataChange AS dataChange#1224781, add#1224725.stats AS stats#1224782, add#1224725.tags AS tags#1224783, add#1224725.deletionVector AS deletionVector#1224784, add#1224725.baseRowId AS baseRowId#1224785L, add#1224725.defaultRowCommitVersion AS defaultRowCommitVersion#1224786L, add#1224725.clusteringProvider AS clusteringProvider#1224787]
Input [10]: [txn#1224724, add#1224725, remove#1224726, metaData#1224727, protocol#1224728, cdc#1224729, checkpointMetadata#1224730, sidecar#1224731, domainMetadata#1224732, commitInfo#1224733]