== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#834940, add#834941, remove#834942, metaData#834943, protocol#834944, cdc#834945, checkpointMetadata#834946, sidecar#834947, domainMetadata#834948, commitInfo#834949]
Arguments: [txn#834940, add#834941, remove#834942, metaData#834943, protocol#834944, cdc#834945, checkpointMetadata#834946, sidecar#834947, domainMetadata#834948, commitInfo#834949], MapPartitionsRDD[39183] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#834940, add#834941, remove#834942, metaData#834943, protocol#834944, cdc#834945, checkpointMetadata#834946, sidecar#834947, domainMetadata#834948, commitInfo#834949]
Condition : (isnotnull(add#834941) AND UDF(add#834941.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#834941.path AS path#834993, add#834941.partitionValues AS partitionValues#834994, add#834941.size AS size#834995L, add#834941.modificationTime AS modificationTime#834996L, add#834941.dataChange AS dataChange#834997, null AS stats#835009, add#834941.tags AS tags#834999, add#834941.deletionVector AS deletionVector#835000, add#834941.baseRowId AS baseRowId#835001L, add#834941.defaultRowCommitVersion AS defaultRowCommitVersion#835002L, add#834941.clusteringProvider AS clusteringProvider#835003]
Input [10]: [txn#834940, add#834941, remove#834942, metaData#834943, protocol#834944, cdc#834945, checkpointMetadata#834946, sidecar#834947, domainMetadata#834948, commitInfo#834949]