== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1006479, add#1006480, remove#1006481, metaData#1006482, protocol#1006483, cdc#1006484, checkpointMetadata#1006485, sidecar#1006486, domainMetadata#1006487, commitInfo#1006488]
Arguments: [txn#1006479, add#1006480, remove#1006481, metaData#1006482, protocol#1006483, cdc#1006484, checkpointMetadata#1006485, sidecar#1006486, domainMetadata#1006487, commitInfo#1006488], MapPartitionsRDD[47068] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1006479, add#1006480, remove#1006481, metaData#1006482, protocol#1006483, cdc#1006484, checkpointMetadata#1006485, sidecar#1006486, domainMetadata#1006487, commitInfo#1006488]
Condition : (isnotnull(add#1006480) AND UDF(add#1006480.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#1006480.path AS path#1006532, add#1006480.partitionValues AS partitionValues#1006533, add#1006480.size AS size#1006534L, add#1006480.modificationTime AS modificationTime#1006535L, add#1006480.dataChange AS dataChange#1006536, null AS stats#1006548, add#1006480.tags AS tags#1006538, add#1006480.deletionVector AS deletionVector#1006539, add#1006480.baseRowId AS baseRowId#1006540L, add#1006480.defaultRowCommitVersion AS defaultRowCommitVersion#1006541L, add#1006480.clusteringProvider AS clusteringProvider#1006542]
Input [10]: [txn#1006479, add#1006480, remove#1006481, metaData#1006482, protocol#1006483, cdc#1006484, checkpointMetadata#1006485, sidecar#1006486, domainMetadata#1006487, commitInfo#1006488]