== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#737784, add#737785, remove#737786, metaData#737787, protocol#737788, cdc#737789, checkpointMetadata#737790, sidecar#737791, domainMetadata#737792, commitInfo#737793]
Arguments: [txn#737784, add#737785, remove#737786, metaData#737787, protocol#737788, cdc#737789, checkpointMetadata#737790, sidecar#737791, domainMetadata#737792, commitInfo#737793], MapPartitionsRDD[34651] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#737784, add#737785, remove#737786, metaData#737787, protocol#737788, cdc#737789, checkpointMetadata#737790, sidecar#737791, domainMetadata#737792, commitInfo#737793]
Condition : (isnotnull(add#737785) AND UDF(add#737785.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#737785.path AS path#737837, add#737785.partitionValues AS partitionValues#737838, add#737785.size AS size#737839L, add#737785.modificationTime AS modificationTime#737840L, add#737785.dataChange AS dataChange#737841, null AS stats#737853, add#737785.tags AS tags#737843, add#737785.deletionVector AS deletionVector#737844, add#737785.baseRowId AS baseRowId#737845L, add#737785.defaultRowCommitVersion AS defaultRowCommitVersion#737846L, add#737785.clusteringProvider AS clusteringProvider#737847]
Input [10]: [txn#737784, add#737785, remove#737786, metaData#737787, protocol#737788, cdc#737789, checkpointMetadata#737790, sidecar#737791, domainMetadata#737792, commitInfo#737793]