== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1224626, add#1224627, remove#1224628, metaData#1224629, protocol#1224630, cdc#1224631, checkpointMetadata#1224632, sidecar#1224633, domainMetadata#1224634, commitInfo#1224635]
Arguments: [txn#1224626, add#1224627, remove#1224628, metaData#1224629, protocol#1224630, cdc#1224631, checkpointMetadata#1224632, sidecar#1224633, domainMetadata#1224634, commitInfo#1224635], MapPartitionsRDD[70420] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1224626, add#1224627, remove#1224628, metaData#1224629, protocol#1224630, cdc#1224631, checkpointMetadata#1224632, sidecar#1224633, domainMetadata#1224634, commitInfo#1224635]
Condition : isnotnull(add#1224627)
(3) Project [codegen id : 1]
Output [11]: [add#1224627.path AS path#1224679, add#1224627.partitionValues AS partitionValues#1224680, add#1224627.size AS size#1224681L, add#1224627.modificationTime AS modificationTime#1224682L, add#1224627.dataChange AS dataChange#1224683, null AS stats#1224690, add#1224627.tags AS tags#1224685, add#1224627.deletionVector AS deletionVector#1224686, add#1224627.baseRowId AS baseRowId#1224687L, add#1224627.defaultRowCommitVersion AS defaultRowCommitVersion#1224688L, add#1224627.clusteringProvider AS clusteringProvider#1224689]
Input [10]: [txn#1224626, add#1224627, remove#1224628, metaData#1224629, protocol#1224630, cdc#1224631, checkpointMetadata#1224632, sidecar#1224633, domainMetadata#1224634, commitInfo#1224635]