== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#23615, add#23616, remove#23617, metaData#23618, protocol#23619, cdc#23620, checkpointMetadata#23621, sidecar#23622, domainMetadata#23623, commitInfo#23624]
Arguments: [txn#23615, add#23616, remove#23617, metaData#23618, protocol#23619, cdc#23620, checkpointMetadata#23621, sidecar#23622, domainMetadata#23623, commitInfo#23624], MapPartitionsRDD[2340] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#23615, add#23616, remove#23617, metaData#23618, protocol#23619, cdc#23620, checkpointMetadata#23621, sidecar#23622, domainMetadata#23623, commitInfo#23624]
Condition : isnotnull(add#23616)
(3) Project [codegen id : 1]
Output [11]: [add#23616.path AS path#23668, add#23616.partitionValues AS partitionValues#23669, add#23616.size AS size#23670L, add#23616.modificationTime AS modificationTime#23671L, add#23616.dataChange AS dataChange#23672, add#23616.stats AS stats#23673, add#23616.tags AS tags#23674, add#23616.deletionVector AS deletionVector#23675, add#23616.baseRowId AS baseRowId#23676L, add#23616.defaultRowCommitVersion AS defaultRowCommitVersion#23677L, add#23616.clusteringProvider AS clusteringProvider#23678]
Input [10]: [txn#23615, add#23616, remove#23617, metaData#23618, protocol#23619, cdc#23620, checkpointMetadata#23621, sidecar#23622, domainMetadata#23623, commitInfo#23624]