== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#11811, add#11812, remove#11813, metaData#11814, protocol#11815, cdc#11816, checkpointMetadata#11817, sidecar#11818, domainMetadata#11819, commitInfo#11820]
Arguments: [txn#11811, add#11812, remove#11813, metaData#11814, protocol#11815, cdc#11816, checkpointMetadata#11817, sidecar#11818, domainMetadata#11819, commitInfo#11820], MapPartitionsRDD[777] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#11811, add#11812, remove#11813, metaData#11814, protocol#11815, cdc#11816, checkpointMetadata#11817, sidecar#11818, domainMetadata#11819, commitInfo#11820]
Condition : isnotnull(add#11812)
(3) Project [codegen id : 1]
Output [11]: [add#11812.path AS path#11864, add#11812.partitionValues AS partitionValues#11865, add#11812.size AS size#11866L, add#11812.modificationTime AS modificationTime#11867L, add#11812.dataChange AS dataChange#11868, add#11812.stats AS stats#11869, add#11812.tags AS tags#11870, add#11812.deletionVector AS deletionVector#11871, add#11812.baseRowId AS baseRowId#11872L, add#11812.defaultRowCommitVersion AS defaultRowCommitVersion#11873L, add#11812.clusteringProvider AS clusteringProvider#11874]
Input [10]: [txn#11811, add#11812, remove#11813, metaData#11814, protocol#11815, cdc#11816, checkpointMetadata#11817, sidecar#11818, domainMetadata#11819, commitInfo#11820]