== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#38562, add#38563, remove#38564, metaData#38565, protocol#38566, cdc#38567, checkpointMetadata#38568, sidecar#38569, domainMetadata#38570, commitInfo#38571]
Arguments: [txn#38562, add#38563, remove#38564, metaData#38565, protocol#38566, cdc#38567, checkpointMetadata#38568, sidecar#38569, domainMetadata#38570, commitInfo#38571], MapPartitionsRDD[1910] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#38562, add#38563, remove#38564, metaData#38565, protocol#38566, cdc#38567, checkpointMetadata#38568, sidecar#38569, domainMetadata#38570, commitInfo#38571]
Condition : isnotnull(add#38563)
(3) Project [codegen id : 1]
Output [11]: [add#38563.path AS path#38615, add#38563.partitionValues AS partitionValues#38616, add#38563.size AS size#38617L, add#38563.modificationTime AS modificationTime#38618L, add#38563.dataChange AS dataChange#38619, add#38563.stats AS stats#38620, add#38563.tags AS tags#38621, add#38563.deletionVector AS deletionVector#38622, add#38563.baseRowId AS baseRowId#38623L, add#38563.defaultRowCommitVersion AS defaultRowCommitVersion#38624L, add#38563.clusteringProvider AS clusteringProvider#38625]
Input [10]: [txn#38562, add#38563, remove#38564, metaData#38565, protocol#38566, cdc#38567, checkpointMetadata#38568, sidecar#38569, domainMetadata#38570, commitInfo#38571]