Skip to content

Commit

Permalink
First cut at neu key-only spine (#439)
Browse files Browse the repository at this point in the history
  • Loading branch information
frankmcsherry authored Dec 1, 2023
1 parent 3182200 commit 98a61c8
Show file tree
Hide file tree
Showing 4 changed files with 457 additions and 11 deletions.
4 changes: 2 additions & 2 deletions examples/spines.rs
Original file line number Diff line number Diff line change
Expand Up @@ -31,14 +31,14 @@ fn main() {

match mode.as_str() {
"new" => {
use differential_dataflow::trace::implementations::ord::ColKeySpine;
use differential_dataflow::trace::implementations::ord_neu::ColKeySpine;
let data = data.arrange::<ColKeySpine<_,_,_>>();
let keys = keys.arrange::<ColKeySpine<_,_,_>>();
keys.join_core(&data, |_k, &(), &()| Option::<()>::None)
.probe_with(&mut probe);
},
"old" => {
use differential_dataflow::trace::implementations::ord::OrdKeySpine;
use differential_dataflow::trace::implementations::ord_neu::OrdKeySpine;
let data = data.arrange::<OrdKeySpine<_,_,_>>();
let keys = keys.arrange::<OrdKeySpine<_,_,_>>();
keys.join_core(&data, |_k, &(), &()| Option::<()>::None)
Expand Down
6 changes: 3 additions & 3 deletions src/trace/implementations/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,13 +45,13 @@ pub(crate) mod merge_batcher_col;

pub use self::merge_batcher::MergeBatcher as Batcher;

pub mod ord;
// pub mod ord;
pub mod ord_neu;
pub mod rhh;

// Opinionated takes on default spines.
pub use self::ord::OrdValSpine as ValSpine;
pub use self::ord::OrdKeySpine as KeySpine;
pub use self::ord_neu::OrdValSpine as ValSpine;
pub use self::ord_neu::OrdKeySpine as KeySpine;

use std::borrow::{Borrow, ToOwned};

Expand Down
Loading

0 comments on commit 98a61c8

Please sign in to comment.