== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#945322, add#945323, remove#945324, metaData#945325, protocol#945326, cdc#945327, checkpointMetadata#945328, sidecar#945329, domainMetadata#945330, commitInfo#945331]
Arguments: [txn#945322, add#945323, remove#945324, metaData#945325, protocol#945326, cdc#945327, checkpointMetadata#945328, sidecar#945329, domainMetadata#945330, commitInfo#945331], MapPartitionsRDD[44253] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#945322, add#945323, remove#945324, metaData#945325, protocol#945326, cdc#945327, checkpointMetadata#945328, sidecar#945329, domainMetadata#945330, commitInfo#945331]
Condition : (isnotnull(add#945323) AND UDF(add#945323.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#945323.path AS path#945375, add#945323.partitionValues AS partitionValues#945376, add#945323.size AS size#945377L, add#945323.modificationTime AS modificationTime#945378L, add#945323.dataChange AS dataChange#945379, null AS stats#945391, add#945323.tags AS tags#945381, add#945323.deletionVector AS deletionVector#945382, add#945323.baseRowId AS baseRowId#945383L, add#945323.defaultRowCommitVersion AS defaultRowCommitVersion#945384L, add#945323.clusteringProvider AS clusteringProvider#945385]
Input [10]: [txn#945322, add#945323, remove#945324, metaData#945325, protocol#945326, cdc#945327, checkpointMetadata#945328, sidecar#945329, domainMetadata#945330, commitInfo#945331]