== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#922411, add#922412, remove#922413, metaData#922414, protocol#922415, cdc#922416, checkpointMetadata#922417, sidecar#922418, domainMetadata#922419, commitInfo#922420]
Arguments: [txn#922411, add#922412, remove#922413, metaData#922414, protocol#922415, cdc#922416, checkpointMetadata#922417, sidecar#922418, domainMetadata#922419, commitInfo#922420], MapPartitionsRDD[43249] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#922411, add#922412, remove#922413, metaData#922414, protocol#922415, cdc#922416, checkpointMetadata#922417, sidecar#922418, domainMetadata#922419, commitInfo#922420]
Condition : (isnotnull(add#922412) AND UDF(add#922412.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#922412.path AS path#922464, add#922412.partitionValues AS partitionValues#922465, add#922412.size AS size#922466L, add#922412.modificationTime AS modificationTime#922467L, add#922412.dataChange AS dataChange#922468, null AS stats#922480, add#922412.tags AS tags#922470, add#922412.deletionVector AS deletionVector#922471, add#922412.baseRowId AS baseRowId#922472L, add#922412.defaultRowCommitVersion AS defaultRowCommitVersion#922473L, add#922412.clusteringProvider AS clusteringProvider#922474]
Input [10]: [txn#922411, add#922412, remove#922413, metaData#922414, protocol#922415, cdc#922416, checkpointMetadata#922417, sidecar#922418, domainMetadata#922419, commitInfo#922420]