== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#68092, add#68093, remove#68094, metaData#68095, protocol#68096, cdc#68097, checkpointMetadata#68098, sidecar#68099, domainMetadata#68100, commitInfo#68101]
Arguments: [txn#68092, add#68093, remove#68094, metaData#68095, protocol#68096, cdc#68097, checkpointMetadata#68098, sidecar#68099, domainMetadata#68100, commitInfo#68101], MapPartitionsRDD[4026] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#68092, add#68093, remove#68094, metaData#68095, protocol#68096, cdc#68097, checkpointMetadata#68098, sidecar#68099, domainMetadata#68100, commitInfo#68101]
Condition : isnotnull(add#68093)
(3) Project [codegen id : 1]
Output [11]: [add#68093.path AS path#68145, add#68093.partitionValues AS partitionValues#68146, add#68093.size AS size#68147L, add#68093.modificationTime AS modificationTime#68148L, add#68093.dataChange AS dataChange#68149, add#68093.stats AS stats#68150, add#68093.tags AS tags#68151, add#68093.deletionVector AS deletionVector#68152, add#68093.baseRowId AS baseRowId#68153L, add#68093.defaultRowCommitVersion AS defaultRowCommitVersion#68154L, add#68093.clusteringProvider AS clusteringProvider#68155]
Input [10]: [txn#68092, add#68093, remove#68094, metaData#68095, protocol#68096, cdc#68097, checkpointMetadata#68098, sidecar#68099, domainMetadata#68100, commitInfo#68101]