== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#921564, add#921565, remove#921566, metaData#921567, protocol#921568, cdc#921569, checkpointMetadata#921570, sidecar#921571, domainMetadata#921572, commitInfo#921573]
Arguments: [txn#921564, add#921565, remove#921566, metaData#921567, protocol#921568, cdc#921569, checkpointMetadata#921570, sidecar#921571, domainMetadata#921572, commitInfo#921573], MapPartitionsRDD[43154] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#921564, add#921565, remove#921566, metaData#921567, protocol#921568, cdc#921569, checkpointMetadata#921570, sidecar#921571, domainMetadata#921572, commitInfo#921573]
Condition : (isnotnull(add#921565) AND UDF(add#921565.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#921565.path AS path#921617, add#921565.partitionValues AS partitionValues#921618, add#921565.size AS size#921619L, add#921565.modificationTime AS modificationTime#921620L, add#921565.dataChange AS dataChange#921621, null AS stats#921633, add#921565.tags AS tags#921623, add#921565.deletionVector AS deletionVector#921624, add#921565.baseRowId AS baseRowId#921625L, add#921565.defaultRowCommitVersion AS defaultRowCommitVersion#921626L, add#921565.clusteringProvider AS clusteringProvider#921627]
Input [10]: [txn#921564, add#921565, remove#921566, metaData#921567, protocol#921568, cdc#921569, checkpointMetadata#921570, sidecar#921571, domainMetadata#921572, commitInfo#921573]