== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1239068, add#1239069, remove#1239070, metaData#1239071, protocol#1239072, cdc#1239073, checkpointMetadata#1239074, sidecar#1239075, domainMetadata#1239076, commitInfo#1239077]
Arguments: [txn#1239068, add#1239069, remove#1239070, metaData#1239071, protocol#1239072, cdc#1239073, checkpointMetadata#1239074, sidecar#1239075, domainMetadata#1239076, commitInfo#1239077], MapPartitionsRDD[71056] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1239068, add#1239069, remove#1239070, metaData#1239071, protocol#1239072, cdc#1239073, checkpointMetadata#1239074, sidecar#1239075, domainMetadata#1239076, commitInfo#1239077]
Condition : isnotnull(add#1239069)
(3) Project [codegen id : 1]
Output [11]: [add#1239069.path AS path#1239121, add#1239069.partitionValues AS partitionValues#1239122, add#1239069.size AS size#1239123L, add#1239069.modificationTime AS modificationTime#1239124L, add#1239069.dataChange AS dataChange#1239125, add#1239069.stats AS stats#1239126, add#1239069.tags AS tags#1239127, add#1239069.deletionVector AS deletionVector#1239128, add#1239069.baseRowId AS baseRowId#1239129L, add#1239069.defaultRowCommitVersion AS defaultRowCommitVersion#1239130L, add#1239069.clusteringProvider AS clusteringProvider#1239131]
Input [10]: [txn#1239068, add#1239069, remove#1239070, metaData#1239071, protocol#1239072, cdc#1239073, checkpointMetadata#1239074, sidecar#1239075, domainMetadata#1239076, commitInfo#1239077]