== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13791001, add#13791002, remove#13791003, metaData#13791004, protocol#13791005, cdc#13791006, checkpointMetadata#13791007, sidecar#13791008, domainMetadata#13791009, commitInfo#13791010]
Arguments: [txn#13791001, add#13791002, remove#13791003, metaData#13791004, protocol#13791005, cdc#13791006, checkpointMetadata#13791007, sidecar#13791008, domainMetadata#13791009, commitInfo#13791010], MapPartitionsRDD[789129] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13791001, add#13791002, remove#13791003, metaData#13791004, protocol#13791005, cdc#13791006, checkpointMetadata#13791007, sidecar#13791008, domainMetadata#13791009, commitInfo#13791010]
Condition : isnotnull(add#13791002)
(3) Project [codegen id : 1]
Output [11]: [add#13791002.path AS path#13791054, add#13791002.partitionValues AS partitionValues#13791055, add#13791002.size AS size#13791056L, add#13791002.modificationTime AS modificationTime#13791057L, add#13791002.dataChange AS dataChange#13791058, null AS stats#13791065, add#13791002.tags AS tags#13791060, add#13791002.deletionVector AS deletionVector#13791061, add#13791002.baseRowId AS baseRowId#13791062L, add#13791002.defaultRowCommitVersion AS defaultRowCommitVersion#13791063L, add#13791002.clusteringProvider AS clusteringProvider#13791064]
Input [10]: [txn#13791001, add#13791002, remove#13791003, metaData#13791004, protocol#13791005, cdc#13791006, checkpointMetadata#13791007, sidecar#13791008, domainMetadata#13791009, commitInfo#13791010]