== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#945606, add#945607, remove#945608, metaData#945609, protocol#945610, cdc#945611, checkpointMetadata#945612, sidecar#945613, domainMetadata#945614, commitInfo#945615]
Arguments: [txn#945606, add#945607, remove#945608, metaData#945609, protocol#945610, cdc#945611, checkpointMetadata#945612, sidecar#945613, domainMetadata#945614, commitInfo#945615], MapPartitionsRDD[44273] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#945606, add#945607, remove#945608, metaData#945609, protocol#945610, cdc#945611, checkpointMetadata#945612, sidecar#945613, domainMetadata#945614, commitInfo#945615]
Condition : (isnotnull(add#945607) AND UDF(add#945607.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#945607.path AS path#945659, add#945607.partitionValues AS partitionValues#945660, add#945607.size AS size#945661L, add#945607.modificationTime AS modificationTime#945662L, add#945607.dataChange AS dataChange#945663, null AS stats#945675, add#945607.tags AS tags#945665, add#945607.deletionVector AS deletionVector#945666, add#945607.baseRowId AS baseRowId#945667L, add#945607.defaultRowCommitVersion AS defaultRowCommitVersion#945668L, add#945607.clusteringProvider AS clusteringProvider#945669]
Input [10]: [txn#945606, add#945607, remove#945608, metaData#945609, protocol#945610, cdc#945611, checkpointMetadata#945612, sidecar#945613, domainMetadata#945614, commitInfo#945615]