== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13801636, add#13801637, remove#13801638, metaData#13801639, protocol#13801640, cdc#13801641, checkpointMetadata#13801642, sidecar#13801643, domainMetadata#13801644, commitInfo#13801645]
Arguments: [txn#13801636, add#13801637, remove#13801638, metaData#13801639, protocol#13801640, cdc#13801641, checkpointMetadata#13801642, sidecar#13801643, domainMetadata#13801644, commitInfo#13801645], MapPartitionsRDD[789595] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13801636, add#13801637, remove#13801638, metaData#13801639, protocol#13801640, cdc#13801641, checkpointMetadata#13801642, sidecar#13801643, domainMetadata#13801644, commitInfo#13801645]
Condition : isnotnull(add#13801637)
(3) Project [codegen id : 1]
Output [11]: [add#13801637.path AS path#13801689, add#13801637.partitionValues AS partitionValues#13801690, add#13801637.size AS size#13801691L, add#13801637.modificationTime AS modificationTime#13801692L, add#13801637.dataChange AS dataChange#13801693, null AS stats#13801700, add#13801637.tags AS tags#13801695, add#13801637.deletionVector AS deletionVector#13801696, add#13801637.baseRowId AS baseRowId#13801697L, add#13801637.defaultRowCommitVersion AS defaultRowCommitVersion#13801698L, add#13801637.clusteringProvider AS clusteringProvider#13801699]
Input [10]: [txn#13801636, add#13801637, remove#13801638, metaData#13801639, protocol#13801640, cdc#13801641, checkpointMetadata#13801642, sidecar#13801643, domainMetadata#13801644, commitInfo#13801645]