== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1008032, add#1008033, remove#1008034, metaData#1008035, protocol#1008036, cdc#1008037, checkpointMetadata#1008038, sidecar#1008039, domainMetadata#1008040, commitInfo#1008041]
Arguments: [txn#1008032, add#1008033, remove#1008034, metaData#1008035, protocol#1008036, cdc#1008037, checkpointMetadata#1008038, sidecar#1008039, domainMetadata#1008040, commitInfo#1008041], MapPartitionsRDD[47123] at save at FileStorageAdapterImpl.java:308, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1008032, add#1008033, remove#1008034, metaData#1008035, protocol#1008036, cdc#1008037, checkpointMetadata#1008038, sidecar#1008039, domainMetadata#1008040, commitInfo#1008041]
Condition : (isnotnull(add#1008033) AND UDF(add#1008033.partitionValues))
(3) Project [codegen id : 1]
Output [11]: [add#1008033.path AS path#1008085, add#1008033.partitionValues AS partitionValues#1008086, add#1008033.size AS size#1008087L, add#1008033.modificationTime AS modificationTime#1008088L, add#1008033.dataChange AS dataChange#1008089, null AS stats#1008101, add#1008033.tags AS tags#1008091, add#1008033.deletionVector AS deletionVector#1008092, add#1008033.baseRowId AS baseRowId#1008093L, add#1008033.defaultRowCommitVersion AS defaultRowCommitVersion#1008094L, add#1008033.clusteringProvider AS clusteringProvider#1008095]
Input [10]: [txn#1008032, add#1008033, remove#1008034, metaData#1008035, protocol#1008036, cdc#1008037, checkpointMetadata#1008038, sidecar#1008039, domainMetadata#1008040, commitInfo#1008041]