bags union

2 years ago · c099ece0a9
parent 218757ce21
commit c099ece0a9
1 changed files with 6 additions and 2 deletions
--- a/src/db/plan.rs
+++ b/src/db/plan.rs
@ -252,8 +252,12 @@ impl<'a> MegaTupleIt<'a> {
            MegaTupleIt::KeyedDifferenceIt { .. } => {
                todo!()
            }
-            MegaTupleIt::BagsUnionIt { .. } => {
-                todo!()
+            MegaTupleIt::BagsUnionIt { bags } => {
+                let bags = bags.iter().map(|i| i.iter()).collect();
+                Box::new(BagsUnionIterator {
+                    bags,
+                    current: 0
+                })
            }
        }
    }