== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#18202, add#18203, remove#18204, metaData#18205, protocol#18206, cdc#18207, checkpointMetadata#18208, sidecar#18209, domainMetadata#18210, commitInfo#18211]
Arguments: [txn#18202, add#18203, remove#18204, metaData#18205, protocol#18206, cdc#18207, checkpointMetadata#18208, sidecar#18209, domainMetadata#18210, commitInfo#18211], MapPartitionsRDD[1806] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#18202, add#18203, remove#18204, metaData#18205, protocol#18206, cdc#18207, checkpointMetadata#18208, sidecar#18209, domainMetadata#18210, commitInfo#18211]
Condition : isnotnull(add#18203)
(3) Project [codegen id : 1]
Output [11]: [add#18203.path AS path#18255, add#18203.partitionValues AS partitionValues#18256, add#18203.size AS size#18257L, add#18203.modificationTime AS modificationTime#18258L, add#18203.dataChange AS dataChange#18259, null AS stats#18266, add#18203.tags AS tags#18261, add#18203.deletionVector AS deletionVector#18262, add#18203.baseRowId AS baseRowId#18263L, add#18203.defaultRowCommitVersion AS defaultRowCommitVersion#18264L, add#18203.clusteringProvider AS clusteringProvider#18265]
Input [10]: [txn#18202, add#18203, remove#18204, metaData#18205, protocol#18206, cdc#18207, checkpointMetadata#18208, sidecar#18209, domainMetadata#18210, commitInfo#18211]