== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#739337, add#739338, remove#739339, metaData#739340, protocol#739341, cdc#739342, checkpointMetadata#739343, sidecar#739344, domainMetadata#739345, commitInfo#739346]
Arguments: [txn#739337, add#739338, remove#739339, metaData#739340, protocol#739341, cdc#739342, checkpointMetadata#739343, sidecar#739344, domainMetadata#739345, commitInfo#739346], MapPartitionsRDD[34717] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#739337, add#739338, remove#739339, metaData#739340, protocol#739341, cdc#739342, checkpointMetadata#739343, sidecar#739344, domainMetadata#739345, commitInfo#739346]
Condition : (isnotnull(add#739338) AND UDF(add#739338.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#739338.path AS path#739390, add#739338.partitionValues AS partitionValues#739391, add#739338.size AS size#739392L, add#739338.modificationTime AS modificationTime#739393L, add#739338.dataChange AS dataChange#739394, null AS stats#739406, add#739338.tags AS tags#739396, add#739338.deletionVector AS deletionVector#739397, add#739338.baseRowId AS baseRowId#739398L, add#739338.defaultRowCommitVersion AS defaultRowCommitVersion#739399L, add#739338.clusteringProvider AS clusteringProvider#739400]
Input [10]: [txn#739337, add#739338, remove#739339, metaData#739340, protocol#739341, cdc#739342, checkpointMetadata#739343, sidecar#739344, domainMetadata#739345, commitInfo#739346]