== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#739728, add#739729, remove#739730, metaData#739731, protocol#739732, cdc#739733, checkpointMetadata#739734, sidecar#739735, domainMetadata#739736, commitInfo#739737]
Arguments: [txn#739728, add#739729, remove#739730, metaData#739731, protocol#739732, cdc#739733, checkpointMetadata#739734, sidecar#739735, domainMetadata#739736, commitInfo#739737], MapPartitionsRDD[34774] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#739728, add#739729, remove#739730, metaData#739731, protocol#739732, cdc#739733, checkpointMetadata#739734, sidecar#739735, domainMetadata#739736, commitInfo#739737]
Condition : (isnotnull(add#739729) AND UDF(add#739729.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#739729.path AS path#739781, add#739729.partitionValues AS partitionValues#739782, add#739729.size AS size#739783L, add#739729.modificationTime AS modificationTime#739784L, add#739729.dataChange AS dataChange#739785, null AS stats#739797, add#739729.tags AS tags#739787, add#739729.deletionVector AS deletionVector#739788, add#739729.baseRowId AS baseRowId#739789L, add#739729.defaultRowCommitVersion AS defaultRowCommitVersion#739790L, add#739729.clusteringProvider AS clusteringProvider#739791]
Input [10]: [txn#739728, add#739729, remove#739730, metaData#739731, protocol#739732, cdc#739733, checkpointMetadata#739734, sidecar#739735, domainMetadata#739736, commitInfo#739737]