== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#49672, add#49673, remove#49674, metaData#49675, protocol#49676, cdc#49677, checkpointMetadata#49678, sidecar#49679, domainMetadata#49680, commitInfo#49681]
Arguments: [txn#49672, add#49673, remove#49674, metaData#49675, protocol#49676, cdc#49677, checkpointMetadata#49678, sidecar#49679, domainMetadata#49680, commitInfo#49681], MapPartitionsRDD[2558] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#49672, add#49673, remove#49674, metaData#49675, protocol#49676, cdc#49677, checkpointMetadata#49678, sidecar#49679, domainMetadata#49680, commitInfo#49681]
Condition : isnotnull(add#49673)
(3) Project [codegen id : 1]
Output [11]: [add#49673.path AS path#49725, add#49673.partitionValues AS partitionValues#49726, add#49673.size AS size#49727L, add#49673.modificationTime AS modificationTime#49728L, add#49673.dataChange AS dataChange#49729, add#49673.stats AS stats#49730, add#49673.tags AS tags#49731, add#49673.deletionVector AS deletionVector#49732, add#49673.baseRowId AS baseRowId#49733L, add#49673.defaultRowCommitVersion AS defaultRowCommitVersion#49734L, add#49673.clusteringProvider AS clusteringProvider#49735]
Input [10]: [txn#49672, add#49673, remove#49674, metaData#49675, protocol#49676, cdc#49677, checkpointMetadata#49678, sidecar#49679, domainMetadata#49680, commitInfo#49681]