== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#11713, add#11714, remove#11715, metaData#11716, protocol#11717, cdc#11718, checkpointMetadata#11719, sidecar#11720, domainMetadata#11721, commitInfo#11722]
Arguments: [txn#11713, add#11714, remove#11715, metaData#11716, protocol#11717, cdc#11718, checkpointMetadata#11719, sidecar#11720, domainMetadata#11721, commitInfo#11722], MapPartitionsRDD[773] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#11713, add#11714, remove#11715, metaData#11716, protocol#11717, cdc#11718, checkpointMetadata#11719, sidecar#11720, domainMetadata#11721, commitInfo#11722]
Condition : isnotnull(add#11714)
(3) Project [codegen id : 1]
Output [11]: [add#11714.path AS path#11766, add#11714.partitionValues AS partitionValues#11767, add#11714.size AS size#11768L, add#11714.modificationTime AS modificationTime#11769L, add#11714.dataChange AS dataChange#11770, null AS stats#11777, add#11714.tags AS tags#11772, add#11714.deletionVector AS deletionVector#11773, add#11714.baseRowId AS baseRowId#11774L, add#11714.defaultRowCommitVersion AS defaultRowCommitVersion#11775L, add#11714.clusteringProvider AS clusteringProvider#11776]
Input [10]: [txn#11713, add#11714, remove#11715, metaData#11716, protocol#11717, cdc#11718, checkpointMetadata#11719, sidecar#11720, domainMetadata#11721, commitInfo#11722]