== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1021158, add#1021159, remove#1021160, metaData#1021161, protocol#1021162, cdc#1021163, checkpointMetadata#1021164, sidecar#1021165, domainMetadata#1021166, commitInfo#1021167]
Arguments: [txn#1021158, add#1021159, remove#1021160, metaData#1021161, protocol#1021162, cdc#1021163, checkpointMetadata#1021164, sidecar#1021165, domainMetadata#1021166, commitInfo#1021167], MapPartitionsRDD[50965] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1021158, add#1021159, remove#1021160, metaData#1021161, protocol#1021162, cdc#1021163, checkpointMetadata#1021164, sidecar#1021165, domainMetadata#1021166, commitInfo#1021167]
Condition : isnotnull(add#1021159)
(3) Project [codegen id : 1]
Output [11]: [add#1021159.path AS path#1021211, add#1021159.partitionValues AS partitionValues#1021212, add#1021159.size AS size#1021213L, add#1021159.modificationTime AS modificationTime#1021214L, add#1021159.dataChange AS dataChange#1021215, null AS stats#1021222, add#1021159.tags AS tags#1021217, add#1021159.deletionVector AS deletionVector#1021218, add#1021159.baseRowId AS baseRowId#1021219L, add#1021159.defaultRowCommitVersion AS defaultRowCommitVersion#1021220L, add#1021159.clusteringProvider AS clusteringProvider#1021221]
Input [10]: [txn#1021158, add#1021159, remove#1021160, metaData#1021161, protocol#1021162, cdc#1021163, checkpointMetadata#1021164, sidecar#1021165, domainMetadata#1021166, commitInfo#1021167]