== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#834092, add#834093, remove#834094, metaData#834095, protocol#834096, cdc#834097, checkpointMetadata#834098, sidecar#834099, domainMetadata#834100, commitInfo#834101]
Arguments: [txn#834092, add#834093, remove#834094, metaData#834095, protocol#834096, cdc#834097, checkpointMetadata#834098, sidecar#834099, domainMetadata#834100, commitInfo#834101], MapPartitionsRDD[39088] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#834092, add#834093, remove#834094, metaData#834095, protocol#834096, cdc#834097, checkpointMetadata#834098, sidecar#834099, domainMetadata#834100, commitInfo#834101]
Condition : (isnotnull(add#834093) AND UDF(add#834093.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#834093.path AS path#834145, add#834093.partitionValues AS partitionValues#834146, add#834093.size AS size#834147L, add#834093.modificationTime AS modificationTime#834148L, add#834093.dataChange AS dataChange#834149, null AS stats#834161, add#834093.tags AS tags#834151, add#834093.deletionVector AS deletionVector#834152, add#834093.baseRowId AS baseRowId#834153L, add#834093.defaultRowCommitVersion AS defaultRowCommitVersion#834154L, add#834093.clusteringProvider AS clusteringProvider#834155]
Input [10]: [txn#834092, add#834093, remove#834094, metaData#834095, protocol#834096, cdc#834097, checkpointMetadata#834098, sidecar#834099, domainMetadata#834100, commitInfo#834101]