== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#832442, add#832443, remove#832444, metaData#832445, protocol#832446, cdc#832447, checkpointMetadata#832448, sidecar#832449, domainMetadata#832450, commitInfo#832451]
Arguments: [txn#832442, add#832443, remove#832444, metaData#832445, protocol#832446, cdc#832447, checkpointMetadata#832448, sidecar#832449, domainMetadata#832450, commitInfo#832451], MapPartitionsRDD[39018] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#832442, add#832443, remove#832444, metaData#832445, protocol#832446, cdc#832447, checkpointMetadata#832448, sidecar#832449, domainMetadata#832450, commitInfo#832451]
Condition : (isnotnull(add#832443) AND UDF(add#832443.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#832443.path AS path#832495, add#832443.partitionValues AS partitionValues#832496, add#832443.size AS size#832497L, add#832443.modificationTime AS modificationTime#832498L, add#832443.dataChange AS dataChange#832499, null AS stats#832511, add#832443.tags AS tags#832501, add#832443.deletionVector AS deletionVector#832502, add#832443.baseRowId AS baseRowId#832503L, add#832443.defaultRowCommitVersion AS defaultRowCommitVersion#832504L, add#832443.clusteringProvider AS clusteringProvider#832505]
Input [10]: [txn#832442, add#832443, remove#832444, metaData#832445, protocol#832446, cdc#832447, checkpointMetadata#832448, sidecar#832449, domainMetadata#832450, commitInfo#832451]