== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#919914, add#919915, remove#919916, metaData#919917, protocol#919918, cdc#919919, checkpointMetadata#919920, sidecar#919921, domainMetadata#919922, commitInfo#919923]
Arguments: [txn#919914, add#919915, remove#919916, metaData#919917, protocol#919918, cdc#919919, checkpointMetadata#919920, sidecar#919921, domainMetadata#919922, commitInfo#919923], MapPartitionsRDD[43084] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#919914, add#919915, remove#919916, metaData#919917, protocol#919918, cdc#919919, checkpointMetadata#919920, sidecar#919921, domainMetadata#919922, commitInfo#919923]
Condition : (isnotnull(add#919915) AND UDF(add#919915.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#919915.path AS path#919967, add#919915.partitionValues AS partitionValues#919968, add#919915.size AS size#919969L, add#919915.modificationTime AS modificationTime#919970L, add#919915.dataChange AS dataChange#919971, null AS stats#919983, add#919915.tags AS tags#919973, add#919915.deletionVector AS deletionVector#919974, add#919915.baseRowId AS baseRowId#919975L, add#919915.defaultRowCommitVersion AS defaultRowCommitVersion#919976L, add#919915.clusteringProvider AS clusteringProvider#919977]
Input [10]: [txn#919914, add#919915, remove#919916, metaData#919917, protocol#919918, cdc#919919, checkpointMetadata#919920, sidecar#919921, domainMetadata#919922, commitInfo#919923]