== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#905817, add#905818, remove#905819, metaData#905820, protocol#905821, cdc#905822, checkpointMetadata#905823, sidecar#905824, domainMetadata#905825, commitInfo#905826]
Arguments: [txn#905817, add#905818, remove#905819, metaData#905820, protocol#905821, cdc#905822, checkpointMetadata#905823, sidecar#905824, domainMetadata#905825, commitInfo#905826], MapPartitionsRDD[42496] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#905817, add#905818, remove#905819, metaData#905820, protocol#905821, cdc#905822, checkpointMetadata#905823, sidecar#905824, domainMetadata#905825, commitInfo#905826]
Condition : isnotnull(add#905818)
(3) Project [codegen id : 1]
Output [11]: [add#905818.path AS path#905870, add#905818.partitionValues AS partitionValues#905871, add#905818.size AS size#905872L, add#905818.modificationTime AS modificationTime#905873L, add#905818.dataChange AS dataChange#905874, add#905818.stats AS stats#905875, add#905818.tags AS tags#905876, add#905818.deletionVector AS deletionVector#905877, add#905818.baseRowId AS baseRowId#905878L, add#905818.defaultRowCommitVersion AS defaultRowCommitVersion#905879L, add#905818.clusteringProvider AS clusteringProvider#905880]
Input [10]: [txn#905817, add#905818, remove#905819, metaData#905820, protocol#905821, cdc#905822, checkpointMetadata#905823, sidecar#905824, domainMetadata#905825, commitInfo#905826]