== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1008521, add#1008522, remove#1008523, metaData#1008524, protocol#1008525, cdc#1008526, checkpointMetadata#1008527, sidecar#1008528, domainMetadata#1008529, commitInfo#1008530]
Arguments: [txn#1008521, add#1008522, remove#1008523, metaData#1008524, protocol#1008525, cdc#1008526, checkpointMetadata#1008527, sidecar#1008528, domainMetadata#1008529, commitInfo#1008530], MapPartitionsRDD[47185] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1008521, add#1008522, remove#1008523, metaData#1008524, protocol#1008525, cdc#1008526, checkpointMetadata#1008527, sidecar#1008528, domainMetadata#1008529, commitInfo#1008530]
Condition : (isnotnull(add#1008522) AND UDF(add#1008522.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#1008522.path AS path#1008574, add#1008522.partitionValues AS partitionValues#1008575, add#1008522.size AS size#1008576L, add#1008522.modificationTime AS modificationTime#1008577L, add#1008522.dataChange AS dataChange#1008578, null AS stats#1008590, add#1008522.tags AS tags#1008580, add#1008522.deletionVector AS deletionVector#1008581, add#1008522.baseRowId AS baseRowId#1008582L, add#1008522.defaultRowCommitVersion AS defaultRowCommitVersion#1008583L, add#1008522.clusteringProvider AS clusteringProvider#1008584]
Input [10]: [txn#1008521, add#1008522, remove#1008523, metaData#1008524, protocol#1008525, cdc#1008526, checkpointMetadata#1008527, sidecar#1008528, domainMetadata#1008529, commitInfo#1008530]