== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1208270, add#1208271, remove#1208272, metaData#1208273, protocol#1208274, cdc#1208275, checkpointMetadata#1208276, sidecar#1208277, domainMetadata#1208278, commitInfo#1208279]
Arguments: [txn#1208270, add#1208271, remove#1208272, metaData#1208273, protocol#1208274, cdc#1208275, checkpointMetadata#1208276, sidecar#1208277, domainMetadata#1208278, commitInfo#1208279], MapPartitionsRDD[69447] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1208270, add#1208271, remove#1208272, metaData#1208273, protocol#1208274, cdc#1208275, checkpointMetadata#1208276, sidecar#1208277, domainMetadata#1208278, commitInfo#1208279]
Condition : isnotnull(add#1208271)
(3) Project [codegen id : 1]
Output [11]: [add#1208271.path AS path#1208323, add#1208271.partitionValues AS partitionValues#1208324, add#1208271.size AS size#1208325L, add#1208271.modificationTime AS modificationTime#1208326L, add#1208271.dataChange AS dataChange#1208327, null AS stats#1208334, add#1208271.tags AS tags#1208329, add#1208271.deletionVector AS deletionVector#1208330, add#1208271.baseRowId AS baseRowId#1208331L, add#1208271.defaultRowCommitVersion AS defaultRowCommitVersion#1208332L, add#1208271.clusteringProvider AS clusteringProvider#1208333]
Input [10]: [txn#1208270, add#1208271, remove#1208272, metaData#1208273, protocol#1208274, cdc#1208275, checkpointMetadata#1208276, sidecar#1208277, domainMetadata#1208278, commitInfo#1208279]