== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#16076, add#16077, remove#16078, metaData#16079, protocol#16080, cdc#16081, checkpointMetadata#16082, sidecar#16083, domainMetadata#16084, commitInfo#16085]
Arguments: [txn#16076, add#16077, remove#16078, metaData#16079, protocol#16080, cdc#16081, checkpointMetadata#16082, sidecar#16083, domainMetadata#16084, commitInfo#16085], MapPartitionsRDD[1594] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#16076, add#16077, remove#16078, metaData#16079, protocol#16080, cdc#16081, checkpointMetadata#16082, sidecar#16083, domainMetadata#16084, commitInfo#16085]
Condition : isnotnull(add#16077)
(3) Project [codegen id : 1]
Output [11]: [add#16077.path AS path#16129, add#16077.partitionValues AS partitionValues#16130, add#16077.size AS size#16131L, add#16077.modificationTime AS modificationTime#16132L, add#16077.dataChange AS dataChange#16133, null AS stats#16140, add#16077.tags AS tags#16135, add#16077.deletionVector AS deletionVector#16136, add#16077.baseRowId AS baseRowId#16137L, add#16077.defaultRowCommitVersion AS defaultRowCommitVersion#16138L, add#16077.clusteringProvider AS clusteringProvider#16139]
Input [10]: [txn#16076, add#16077, remove#16078, metaData#16079, protocol#16080, cdc#16081, checkpointMetadata#16082, sidecar#16083, domainMetadata#16084, commitInfo#16085]