From 23f81aefa1187daa80324345e8ba02bcf8083638 Mon Sep 17 00:00:00 2001 From: Moritz Hoffmann Date: Fri, 28 Jun 2024 13:45:59 -0400 Subject: [PATCH] Bump flatcontainer to 0.5 Signed-off-by: Moritz Hoffmann --- src/trace/implementations/ord_neu.rs | 10 +++++----- tests/bfs.rs | 22 +++++++++++----------- 2 files changed, 16 insertions(+), 16 deletions(-) diff --git a/src/trace/implementations/ord_neu.rs b/src/trace/implementations/ord_neu.rs index f161bdc5b..573e9c287 100644 --- a/src/trace/implementations/ord_neu.rs +++ b/src/trace/implementations/ord_neu.rs @@ -10,7 +10,7 @@ use std::rc::Rc; use timely::container::columnation::{TimelyStack}; -use timely::container::flatcontainer::{Containerized, FlatStack}; +use timely::container::flatcontainer::{FlatStack, RegionPreference}; use timely::container::flatcontainer::impls::tuple::{TupleABCRegion, TupleABRegion}; use crate::trace::implementations::chunker::{ColumnationChunker, ContainerChunker, VecChunker}; @@ -50,8 +50,8 @@ pub type FlatValSpine = Spine< /// A trace implementation backed by flatcontainer storage, using [`FlatLayout`] as the layout. pub type FlatValSpineDefault = FlatValSpine< - FlatLayout<::Region, ::Region, ::Region, ::Region>, - TupleABCRegion::Region, ::Region>, ::Region, ::Region>, + FlatLayout<::Region, ::Region, ::Region, ::Region>, + TupleABCRegion::Region, ::Region>, ::Region, ::Region>, C, >; @@ -80,8 +80,8 @@ pub type FlatKeySpine = Spine< /// A trace implementation backed by flatcontainer storage, using [`FlatLayout`] as the layout. pub type FlatKeySpineDefault = FlatKeySpine< - FlatLayout<::Region, <() as Containerized>::Region, ::Region, ::Region>, - TupleABCRegion::Region, <() as Containerized>::Region>, ::Region, ::Region>, + FlatLayout<::Region, <() as RegionPreference>::Region, ::Region, ::Region>, + TupleABCRegion::Region, <() as RegionPreference>::Region>, ::Region, ::Region>, C, >; diff --git a/tests/bfs.rs b/tests/bfs.rs index dee2a9e2c..58471947b 100644 --- a/tests/bfs.rs +++ b/tests/bfs.rs @@ -4,7 +4,7 @@ use rand::{Rng, SeedableRng, StdRng}; use std::sync::{Arc, Mutex}; use timely::{Config, PartialOrder}; -use timely::container::flatcontainer::{Containerized, MirrorRegion, Push, Region, ReserveItems}; +use timely::container::flatcontainer::{MirrorRegion, Push, Region, RegionPreference, ReserveItems}; use timely::dataflow::*; use timely::dataflow::operators::Capture; @@ -296,16 +296,16 @@ fn bfs_flat( roots: &Collection, ) -> Collection where - G::Timestamp: Lattice + Ord + Containerized, - for<'a> G::Timestamp: PartialOrder<<::Region as Region>::ReadItem<'a>>, - ::Region: Region + Push, - for<'a> as Containerized>::Region: Region> + Push<< as Containerized>::Region as Region>::ReadItem<'a>>, - ::Region: Clone + Ord, - for<'a> FlatProductRegion<::Region, MirrorRegion>: Push<&'a Product>, - for<'a> ::Region, MirrorRegion> as Region>::ReadItem<'a>: Copy + Ord + Debug, - Product: for<'a> PartialOrder<< as Containerized>::Region as Region>::ReadItem<'a>>, - for<'a> < as Containerized>::Region as Region>::ReadItem<'a>: PartialOrder>, - for<'a> as Containerized>::Region: ReserveItems<< as Containerized>::Region as Region>::ReadItem<'a>>, + G::Timestamp: Lattice + Ord + RegionPreference, + for<'a> G::Timestamp: PartialOrder<<::Region as Region>::ReadItem<'a>>, + ::Region: Region + Push, + for<'a> as RegionPreference>::Region: Region> + Push<< as RegionPreference>::Region as Region>::ReadItem<'a>>, + ::Region: Clone + Ord, + for<'a> FlatProductRegion<::Region, MirrorRegion>: Push<&'a Product>, + for<'a> ::Region, MirrorRegion> as Region>::ReadItem<'a>: Copy + Ord + Debug, + Product: for<'a> PartialOrder<< as RegionPreference>::Region as Region>::ReadItem<'a>>, + for<'a> < as RegionPreference>::Region as Region>::ReadItem<'a>: PartialOrder>, + for<'a> as RegionPreference>::Region: ReserveItems<< as RegionPreference>::Region as Region>::ReadItem<'a>>, { // initialize roots as reaching themselves at distance 0 let nodes = roots.map(|x| (x, 0));