arrange uses abom batch
@@ -8,12 +8,14 @@ use rand::{Rng, SeedableRng, StdRng};
use differential_dataflow::input::Input;
use differential_dataflow::AsCollection;
-use differential_dataflow::operators::arrange::ArrangeByKey;
+use differential_dataflow::operators::arrange::{Arrange, ArrangeByKey};
use differential_dataflow::operators::group::Group;
use differential_dataflow::operators::join::JoinCore;
use differential_dataflow::operators::Iterate;
use differential_dataflow::operators::Consolidate;
+use differential_dataflow::trace::Trace;
+use differential_dataflow::trace::implementations::ord::OrdValSpineAbom;
// use differential_dataflow::trace::implementations::ord::OrdValSpine;
// use differential_dataflow::trace::{Cursor, Trace};
@@ -97,7 +99,8 @@ fn main() {
})
.probe_with(&mut probe)
.as_collection()
- .arrange_by_key()
+ // .arrange_by_key()
+ .arrange(OrdValSpineAbom::new())
.trace
});
@@ -140,11 +143,8 @@ fn main() {
let (input, query) = scope.new_collection();
query.map(|x| (x, x))
- .arrange_by_key()
.join_core(&edges, |_n, &q, &d| Some((d, q)))
- .arrange_by_key()
.join_core(&edges, |_n, &q, &d| Some((d, q)))
- .arrange_by_key()
.join_core(&edges, |_n, &q, &d| Some((d, q)))
.filter(move |_| inspect)
.map(|x| x.1)
