== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#63515, add#63516, remove#63517, metaData#63518, protocol#63519, cdc#63520, checkpointMetadata#63521, sidecar#63522, domainMetadata#63523, commitInfo#63524]
Arguments: [txn#63515, add#63516, remove#63517, metaData#63518, protocol#63519, cdc#63520, checkpointMetadata#63521, sidecar#63522, domainMetadata#63523, commitInfo#63524], MapPartitionsRDD[3185] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#63515, add#63516, remove#63517, metaData#63518, protocol#63519, cdc#63520, checkpointMetadata#63521, sidecar#63522, domainMetadata#63523, commitInfo#63524]
Condition : isnotnull(add#63516)
(3) Project [codegen id : 1]
Output [11]: [add#63516.path AS path#63568, add#63516.partitionValues AS partitionValues#63569, add#63516.size AS size#63570L, add#63516.modificationTime AS modificationTime#63571L, add#63516.dataChange AS dataChange#63572, add#63516.stats AS stats#63573, add#63516.tags AS tags#63574, add#63516.deletionVector AS deletionVector#63575, add#63516.baseRowId AS baseRowId#63576L, add#63516.defaultRowCommitVersion AS defaultRowCommitVersion#63577L, add#63516.clusteringProvider AS clusteringProvider#63578]
Input [10]: [txn#63515, add#63516, remove#63517, metaData#63518, protocol#63519, cdc#63520, checkpointMetadata#63521, sidecar#63522, domainMetadata#63523, commitInfo#63524]