diff --git a/Cargo.lock b/Cargo.lock index 565fbdf3..1d177325 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -876,7 +876,7 @@ dependencies = [ ] [[package]] -name = "noir" +name = "noir-compute" version = "0.1.0" dependencies = [ "anyhow", diff --git a/Cargo.toml b/Cargo.toml index b2e26e2b..47a3956a 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,10 +1,10 @@ [package] -name = "noir" +name = "noir-compute" description = "Network of Operators In Rust" version = "0.1.0" edition = "2021" authors = [ - "Luca De Martini ", + "Luca De Martini ", "Edoardo Morassutto ", "Marco Donadoni " ] diff --git a/README.md b/README.md index 33fb512a..2c30f395 100644 --- a/README.md +++ b/README.md @@ -19,7 +19,7 @@ The common layout of a Noir program starts with the creation of a `StreamEnviron #### Wordcount ```rs -use noir::prelude::*; +use noir_compute::prelude::*; fn main() { // Convenience method to parse deployment config from CLI arguments @@ -58,7 +58,7 @@ fn tokenize(s: &str) -> Vec { ```rs -use noir::prelude::*; +use noir_compute::prelude::*; fn main() { // Convenience method to parse deployment config from CLI arguments diff --git a/benches/batch_mode.rs b/benches/batch_mode.rs index 2cd8351f..27e10ee8 100644 --- a/benches/batch_mode.rs +++ b/benches/batch_mode.rs @@ -4,10 +4,10 @@ use criterion::{black_box, criterion_group, criterion_main, Criterion, Throughpu use rand::prelude::StdRng; use rand::{Rng, SeedableRng}; -use noir::operator::source::IteratorSource; -use noir::BatchMode; -use noir::EnvironmentConfig; -use noir::StreamEnvironment; +use noir_compute::operator::source::IteratorSource; +use noir_compute::BatchMode; +use noir_compute::EnvironmentConfig; +use noir_compute::StreamEnvironment; fn batch_mode(batch_mode: BatchMode, dataset: &'static [u32]) { let config = EnvironmentConfig::local(4); diff --git a/benches/collatz.rs b/benches/collatz.rs index 83129240..791fd31b 100644 --- a/benches/collatz.rs +++ b/benches/collatz.rs @@ -1,7 +1,7 @@ use criterion::BenchmarkId; use criterion::{criterion_group, criterion_main, Criterion, Throughput}; -use noir::BatchMode; -use noir::StreamEnvironment; +use noir_compute::BatchMode; +use noir_compute::StreamEnvironment; mod common; use common::*; diff --git a/benches/common.rs b/benches/common.rs index 6b625491..593c8c9a 100644 --- a/benches/common.rs +++ b/benches/common.rs @@ -1,13 +1,13 @@ #![allow(unused)] use criterion::{black_box, Bencher}; -use noir::config::{ExecutionRuntime, RemoteHostConfig, RemoteRuntimeConfig}; +use noir_compute::config::{ExecutionRuntime, RemoteHostConfig, RemoteRuntimeConfig}; use std::marker::PhantomData; use std::sync::atomic::{AtomicU16, Ordering}; use std::sync::Arc; use std::time::{Duration, Instant}; -use noir::*; +use noir_compute::*; pub const SAMPLES: usize = 50; diff --git a/benches/connected.rs b/benches/connected.rs index 294f7246..9ee4c9e0 100644 --- a/benches/connected.rs +++ b/benches/connected.rs @@ -1,10 +1,10 @@ use criterion::BenchmarkId; use criterion::{criterion_group, criterion_main, Criterion, Throughput}; use fxhash::FxHashMap; -use noir::operator::Operator; -use noir::EnvironmentConfig; -use noir::Stream; -use noir::StreamEnvironment; +use noir_compute::operator::Operator; +use noir_compute::EnvironmentConfig; +use noir_compute::Stream; +use noir_compute::StreamEnvironment; use rand::prelude::*; use rand::rngs::SmallRng; use serde::{Deserialize, Serialize}; diff --git a/benches/fold_vs_reduce.rs b/benches/fold_vs_reduce.rs index 57949fa1..0e28c2b3 100644 --- a/benches/fold_vs_reduce.rs +++ b/benches/fold_vs_reduce.rs @@ -2,10 +2,10 @@ use criterion::{black_box, criterion_group, criterion_main, Criterion, Throughpu use rand::prelude::StdRng; use rand::{Rng, SeedableRng}; -use noir::operator::source::IteratorSource; -use noir::BatchMode; -use noir::EnvironmentConfig; -use noir::StreamEnvironment; +use noir_compute::operator::source::IteratorSource; +use noir_compute::BatchMode; +use noir_compute::EnvironmentConfig; +use noir_compute::StreamEnvironment; fn fold(dataset: &'static [u32]) { let config = EnvironmentConfig::local(4); diff --git a/benches/nexmark.rs b/benches/nexmark.rs index 33b65df9..82217707 100644 --- a/benches/nexmark.rs +++ b/benches/nexmark.rs @@ -1,11 +1,11 @@ use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion, Throughput}; use nexmark::config::NexmarkConfig; -use noir::operator::window::TransactionOp; -use noir::operator::window::TransactionWindow; -use noir::operator::Operator; -use noir::operator::Timestamp; -use noir::prelude::*; -use noir::Stream; +use noir_compute::operator::window::TransactionOp; +use noir_compute::operator::window::TransactionWindow; +use noir_compute::operator::Operator; +use noir_compute::operator::Timestamp; +use noir_compute::prelude::*; +use noir_compute::Stream; use nexmark::event::*; diff --git a/benches/shuffle.rs b/benches/shuffle.rs index ca3895a7..bfaf6bfd 100644 --- a/benches/shuffle.rs +++ b/benches/shuffle.rs @@ -3,9 +3,9 @@ use criterion::{black_box, criterion_group, criterion_main, Criterion, Throughpu use rand::rngs::SmallRng; use rand::{Rng, SeedableRng}; -use noir::operator::source::IteratorSource; -use noir::BatchMode; -use noir::StreamEnvironment; +use noir_compute::operator::source::IteratorSource; +use noir_compute::BatchMode; +use noir_compute::StreamEnvironment; fn shuffle(dataset: &'static [u32]) { let mut env = StreamEnvironment::default(); diff --git a/benches/wordcount.rs b/benches/wordcount.rs index f03b71d4..442777c3 100644 --- a/benches/wordcount.rs +++ b/benches/wordcount.rs @@ -13,8 +13,8 @@ use once_cell::sync::Lazy; use rand::prelude::StdRng; use rand::SeedableRng; -use noir::BatchMode; -use noir::StreamEnvironment; +use noir_compute::BatchMode; +use noir_compute::StreamEnvironment; mod common; use common::*; diff --git a/examples/car_accidents.rs b/examples/car_accidents.rs index 60956ccd..fbc90e0d 100644 --- a/examples/car_accidents.rs +++ b/examples/car_accidents.rs @@ -4,8 +4,8 @@ use std::str::FromStr; use std::time::Instant; use itertools::Itertools; -use noir::operator::Operator; -use noir::{prelude::*, Stream}; +use noir_compute::operator::Operator; +use noir_compute::{prelude::*, Stream}; use serde::{Deserialize, Serialize}; #[global_allocator] diff --git a/examples/collatz.rs b/examples/collatz.rs index dc99762e..94b73252 100644 --- a/examples/collatz.rs +++ b/examples/collatz.rs @@ -1,4 +1,4 @@ -use noir::prelude::*; +use noir_compute::prelude::*; use std::time::Instant; #[global_allocator] diff --git a/examples/connected_components.rs b/examples/connected_components.rs index 9961c412..cd38cba2 100644 --- a/examples/connected_components.rs +++ b/examples/connected_components.rs @@ -1,7 +1,7 @@ use std::collections::HashSet; use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; use serde::{Deserialize, Serialize}; #[global_allocator] diff --git a/examples/kmeans.rs b/examples/kmeans.rs index 0486925a..cb7fbd1a 100644 --- a/examples/kmeans.rs +++ b/examples/kmeans.rs @@ -6,7 +6,7 @@ use std::time::Instant; use serde::{Deserialize, Serialize}; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/logistic_regression.rs b/examples/logistic_regression.rs index 27cd400d..a18dfa4b 100644 --- a/examples/logistic_regression.rs +++ b/examples/logistic_regression.rs @@ -11,9 +11,9 @@ fn main() {} // // use serde::{Deserialize, Serialize}; // -// use noir::operator::source::CsvSource; -// use noir::EnvironmentConfig; -// use noir::StreamEnvironment; +// use noir_compute::operator::source::CsvSource; +// use noir_compute::EnvironmentConfig; +// use noir_compute::StreamEnvironment; // // #[derive(Serialize, Deserialize, Clone, Copy, Debug)] // struct LabeledPoint { diff --git a/examples/nexmark-latency.rs b/examples/nexmark-latency.rs index 1becc41e..26cb3269 100644 --- a/examples/nexmark-latency.rs +++ b/examples/nexmark-latency.rs @@ -1,10 +1,10 @@ use clap::Parser; use nexmark::config::NexmarkConfig; -use noir::operator::Operator; -use noir::operator::Timestamp; -use noir::prelude::*; -use noir::Replication; -use noir::Stream; +use noir_compute::operator::Operator; +use noir_compute::operator::Timestamp; +use noir_compute::prelude::*; +use noir_compute::Replication; +use noir_compute::Stream; use std::time::Instant; use std::time::SystemTime; use std::time::UNIX_EPOCH; diff --git a/examples/nexmark.rs b/examples/nexmark.rs index c7c911d3..11b39be1 100644 --- a/examples/nexmark.rs +++ b/examples/nexmark.rs @@ -1,13 +1,13 @@ use fxhash::FxHashMap; use nexmark::config::NexmarkConfig; -use noir::operator::window::TransactionOp; -use noir::operator::window::TransactionWindow; -use noir::operator::ElementGenerator; -use noir::operator::Operator; -use noir::operator::StreamElement; -use noir::operator::Timestamp; -use noir::prelude::*; -use noir::Stream; +use noir_compute::operator::window::TransactionOp; +use noir_compute::operator::window::TransactionWindow; +use noir_compute::operator::ElementGenerator; +use noir_compute::operator::Operator; +use noir_compute::operator::StreamElement; +use noir_compute::operator::Timestamp; +use noir_compute::prelude::*; +use noir_compute::Stream; use std::cmp::Reverse; use std::collections::BinaryHeap; use std::time::Instant; diff --git a/examples/pagerank.rs b/examples/pagerank.rs index f4b3bf56..e76d8ea6 100644 --- a/examples/pagerank.rs +++ b/examples/pagerank.rs @@ -1,6 +1,6 @@ use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/pagerank_stateful.rs b/examples/pagerank_stateful.rs index 00a12d56..f9ed0cd3 100644 --- a/examples/pagerank_stateful.rs +++ b/examples/pagerank_stateful.rs @@ -6,7 +6,7 @@ use std::mem::replace; use std::sync::Arc; use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/pagerank_timely.rs b/examples/pagerank_timely.rs index 29af1519..77fa119c 100644 --- a/examples/pagerank_timely.rs +++ b/examples/pagerank_timely.rs @@ -1,6 +1,6 @@ use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; use rand::prelude::*; #[global_allocator] diff --git a/examples/rolling_top_words.rs b/examples/rolling_top_words.rs index 8659f76d..3d0fb16c 100644 --- a/examples/rolling_top_words.rs +++ b/examples/rolling_top_words.rs @@ -3,7 +3,7 @@ use std::time::{Instant, SystemTime}; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; -use noir::prelude::*; +use noir_compute::prelude::*; use rand::prelude::*; const TOPICS: [&str; 50] = [ diff --git a/examples/rolling_top_words_e2e.rs b/examples/rolling_top_words_e2e.rs index 0d393020..cdcd9eac 100644 --- a/examples/rolling_top_words_e2e.rs +++ b/examples/rolling_top_words_e2e.rs @@ -4,7 +4,7 @@ use std::time::Instant; static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; use nanorand::Rng; -use noir::prelude::*; +use noir_compute::prelude::*; const TOPICS: [&str; 50] = [ "#love", diff --git a/examples/simple.rs b/examples/simple.rs index 859c0478..b24c89c2 100644 --- a/examples/simple.rs +++ b/examples/simple.rs @@ -1,4 +1,4 @@ -use noir::prelude::*; +use noir_compute::prelude::*; fn main() { let (config, _args) = EnvironmentConfig::from_args(); diff --git a/examples/transitive_closure.rs b/examples/transitive_closure.rs index 6f158f9c..d5a7a78b 100644 --- a/examples/transitive_closure.rs +++ b/examples/transitive_closure.rs @@ -1,6 +1,6 @@ use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/triangles_fold.rs b/examples/triangles_fold.rs index ee651eed..ebf771eb 100644 --- a/examples/triangles_fold.rs +++ b/examples/triangles_fold.rs @@ -1,6 +1,6 @@ use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/triangles_rich_map.rs b/examples/triangles_rich_map.rs index 9fd6f3af..e30f07c0 100644 --- a/examples/triangles_rich_map.rs +++ b/examples/triangles_rich_map.rs @@ -2,7 +2,7 @@ use std::time::Instant; use itertools::Itertools; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/wordcount.rs b/examples/wordcount.rs index d892e10e..4c1e247c 100644 --- a/examples/wordcount.rs +++ b/examples/wordcount.rs @@ -2,7 +2,7 @@ use std::time::Instant; use regex::Regex; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/wordcount_assoc.rs b/examples/wordcount_assoc.rs index b1706098..f55e02ed 100644 --- a/examples/wordcount_assoc.rs +++ b/examples/wordcount_assoc.rs @@ -2,7 +2,7 @@ use std::time::Instant; use regex::Regex; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/wordcount_opt.rs b/examples/wordcount_opt.rs index 393257ce..b837b7b6 100644 --- a/examples/wordcount_opt.rs +++ b/examples/wordcount_opt.rs @@ -2,7 +2,7 @@ use std::collections::HashMap; use std::hash::BuildHasherDefault; use std::time::Instant; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/examples/wordcount_windowed.rs b/examples/wordcount_windowed.rs index 4c20866f..521041da 100644 --- a/examples/wordcount_windowed.rs +++ b/examples/wordcount_windowed.rs @@ -2,7 +2,7 @@ use std::time::{Duration, Instant}; use regex::Regex; -use noir::prelude::*; +use noir_compute::prelude::*; #[global_allocator] static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc; diff --git a/src/config.rs b/src/config.rs index 261d85df..0f5d9668 100644 --- a/src/config.rs +++ b/src/config.rs @@ -35,7 +35,7 @@ pub const CONFIG_ENV_VAR: &str = "NOIR_CONFIG"; /// ## Local environment /// /// ``` -/// # use noir::{StreamEnvironment, EnvironmentConfig}; +/// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; /// let config = EnvironmentConfig::local(1); /// let mut env = StreamEnvironment::new(config); /// ``` @@ -43,7 +43,7 @@ pub const CONFIG_ENV_VAR: &str = "NOIR_CONFIG"; /// ## Remote environment /// /// ``` -/// # use noir::{StreamEnvironment, EnvironmentConfig}; +/// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; /// # use std::fs::File; /// # use std::io::Write; /// let config = r" @@ -68,7 +68,7 @@ pub const CONFIG_ENV_VAR: &str = "NOIR_CONFIG"; /// their docs. /// /// ```no_run -/// # use noir::{EnvironmentConfig, StreamEnvironment}; +/// # use noir_compute::{EnvironmentConfig, StreamEnvironment}; /// let (config, args) = EnvironmentConfig::from_args(); /// let mut env = StreamEnvironment::new(config); /// ``` diff --git a/src/lib.rs b/src/lib.rs index 5720551b..bf6f3961 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -20,7 +20,7 @@ The common layout of a Noir program starts with the creation of a `StreamEnviron #### Wordcount ```no_run -use noir::prelude::*; +use noir_compute::prelude::*; fn main() { // Convenience method to parse deployment config from CLI arguments @@ -59,7 +59,7 @@ fn tokenize(s: &str) -> Vec { ```no_run -use noir::prelude::*; +use noir_compute::prelude::*; fn main() { // Convenience method to parse deployment config from CLI arguments diff --git a/src/operator/flat_map.rs b/src/operator/flat_map.rs index 08c3d8d3..25eaa6a7 100644 --- a/src/operator/flat_map.rs +++ b/src/operator/flat_map.rs @@ -1,9 +1,9 @@ -use core::iter::{IntoIterator, Iterator}; -use std::fmt::Display; use crate::block::{BlockStructure, OperatorStructure}; use crate::operator::{Operator, StreamElement, Timestamp}; use crate::scheduler::ExecutionMetadata; use crate::stream::KeyedItem; +use core::iter::{IntoIterator, Iterator}; +use std::fmt::Display; #[derive(Derivative)] #[derivative(Debug)] diff --git a/src/operator/iteration/iterate.rs b/src/operator/iteration/iterate.rs index 50a4ea6f..b995042b 100644 --- a/src/operator/iteration/iterate.rs +++ b/src/operator/iteration/iterate.rs @@ -340,8 +340,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new(0..3)).shuffle(); /// let (state, items) = s.iterate( diff --git a/src/operator/iteration/replay.rs b/src/operator/iteration/replay.rs index 6d4116c1..efc3f8ae 100644 --- a/src/operator/iteration/replay.rs +++ b/src/operator/iteration/replay.rs @@ -236,8 +236,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new(0..3)).shuffle(); /// let state = s.replay( diff --git a/src/operator/join/mod.rs b/src/operator/join/mod.rs index 02e0cf95..8e1b88c4 100644 --- a/src/operator/join/mod.rs +++ b/src/operator/join/mod.rs @@ -99,8 +99,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(0..5u8)); /// let s2 = env.stream(IteratorSource::new(0..5i32)); @@ -147,8 +147,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(0..5u8)); /// let s2 = env.stream(IteratorSource::new(0..5i32)); @@ -196,8 +196,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(0..5u8)); /// let s2 = env.stream(IteratorSource::new(0..5i32)); @@ -248,8 +248,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(0..5u8)); /// let s2 = env.stream(IteratorSource::new(0..5i32)); @@ -257,8 +257,8 @@ where /// ``` /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(0..5u8)); /// let s2 = env.stream(IteratorSource::new(0..5i32)); diff --git a/src/operator/key_by.rs b/src/operator/key_by.rs index 646ea4ec..c4953e99 100644 --- a/src/operator/key_by.rs +++ b/src/operator/key_by.rs @@ -51,10 +51,7 @@ where Op: Operator, { pub fn new(prev: Op, keyer: Keyer) -> Self { - Self { - prev, - keyer, - } + Self { prev, keyer } } } diff --git a/src/operator/map.rs b/src/operator/map.rs index 24da8081..7b86e867 100644 --- a/src/operator/map.rs +++ b/src/operator/map.rs @@ -51,10 +51,7 @@ where Op: Operator, { pub(super) fn new(prev: Op, f: F) -> Self { - Self { - prev, - f, - } + Self { prev, f } } } diff --git a/src/operator/merge.rs b/src/operator/merge.rs index 33bc9a1d..b1fdfc40 100644 --- a/src/operator/merge.rs +++ b/src/operator/merge.rs @@ -25,8 +25,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new((0..10))); /// let s2 = env.stream(IteratorSource::new((10..20))); diff --git a/src/operator/mod.rs b/src/operator/mod.rs index 549a47cc..ccc0e0af 100644 --- a/src/operator/mod.rs +++ b/src/operator/mod.rs @@ -309,9 +309,9 @@ where /// will be inserted. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// use noir::operator::Timestamp; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// use noir_compute::operator::Timestamp; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// /// let s = env.stream(IteratorSource::new((0..10))); @@ -345,9 +345,9 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// use noir::BatchMode; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// use noir_compute::BatchMode; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// /// let s = env.stream(IteratorSource::new((0..10))); @@ -366,8 +366,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// let res = s.filter_map(|n| if n % 2 == 0 { Some(n * 3) } else { None }).collect_vec(); @@ -391,8 +391,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// let res = s.filter(|&n| n % 2 == 0).collect_vec(); @@ -433,8 +433,8 @@ where /// This will emit only the _positive prefix-sums_. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new(std::array::IntoIter::new([1, 2, -5, 3, 1]))); /// let res = s.rich_filter_map({ @@ -479,8 +479,8 @@ where /// there are more replicas. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((1..=5))); /// let res = s.rich_map({ @@ -500,8 +500,8 @@ where /// the `enumerate` function in Python. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((1..=5))); /// let res = s.rich_map({ @@ -533,8 +533,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.map(|n| n * 10).collect_vec(); @@ -561,8 +561,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # tokio::runtime::Runtime::new() /// # .unwrap() /// # .block_on(base()); @@ -627,8 +627,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # tokio::runtime::Runtime::new() /// # .unwrap() /// # .block_on(base()); @@ -660,8 +660,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((5..15))); /// let res = s.map_memo_by(|n| (n * n) % 7, |n| n % 7, 5).collect_vec(); @@ -708,8 +708,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.fold(0, |acc, value| *acc += value).collect_vec(); @@ -754,8 +754,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.fold_assoc(0, |acc, value| *acc += value, |acc, value| *acc += value).collect_vec(); @@ -801,8 +801,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -857,8 +857,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.key_by(|&n| n % 2).collect_vec(); @@ -882,8 +882,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// s.inspect(|n| println!("Item: {}", n)).for_each(std::mem::drop); @@ -914,8 +914,8 @@ where /// This will emit only the _positive prefix-sums_. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..=3))); /// let res = s.rich_flat_map({ @@ -978,8 +978,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..3))); /// let res = s.flat_map(|n| vec![n, n]).collect_vec(); @@ -1003,8 +1003,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// s.for_each(|n| println!("Item: {}", n)); @@ -1026,8 +1026,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new(vec![ /// vec![1, 2, 3], @@ -1065,8 +1065,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// s.broadcast(); @@ -1091,8 +1091,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let keyed = s.group_by(|&n| n % 2); // partition even and odd elements @@ -1124,8 +1124,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1173,8 +1173,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1237,8 +1237,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1300,8 +1300,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1342,8 +1342,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1399,8 +1399,8 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s @@ -1515,8 +1515,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream_iter(0..5); /// let res = s.reduce(|a, b| a + b).collect::>(); @@ -1560,8 +1560,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.reduce_assoc(|a, b| a + b).collect_vec(); @@ -1601,7 +1601,7 @@ where /// ## Example /// /// ``` - /// # use noir::prelude::*; + /// # use noir_compute::prelude::*; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// # let s = env.stream_iter(0..10); /// let mut routes = s.route() @@ -1631,8 +1631,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.shuffle(); @@ -1650,8 +1650,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let mut splits = s.split(3); @@ -1686,8 +1686,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new(vec!['A', 'B', 'C', 'D'].into_iter())); /// let s2 = env.stream(IteratorSource::new(vec![1, 2, 3].into_iter())); @@ -1728,8 +1728,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10u32))); /// let rx = s.collect_channel(); @@ -1759,8 +1759,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10u32))); /// let rx = s.collect_channel(); @@ -1791,8 +1791,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// let res = s.collect_vec(); @@ -1822,8 +1822,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// let res = s.collect_vec(); @@ -1852,8 +1852,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))); /// let res = s.collect_vec(); @@ -1885,8 +1885,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # tokio::runtime::Runtime::new() /// # .unwrap() /// # .block_on(base()); @@ -1926,8 +1926,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream_iter((0..4).cycle().take(10)); /// let res = s.map_memo(|n| n * n, 5).collect_vec(); @@ -1972,9 +1972,9 @@ where /// will be inserted. /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// use noir::operator::Timestamp; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// use noir_compute::operator::Timestamp; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// /// let s = env.stream(IteratorSource::new((0..10))); @@ -2011,9 +2011,9 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// use noir::BatchMode; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// use noir_compute::BatchMode; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// /// let s = env.stream(IteratorSource::new((0..10))).group_by(|&n| n % 2); @@ -2032,8 +2032,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))).group_by(|&n| n % 2); /// let res = s.filter_map(|(_key, n)| if n % 3 == 0 { Some(n * 4) } else { None }).collect_vec(); @@ -2061,8 +2061,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10))).group_by(|&n| n % 2); /// let res = s.filter(|&(_key, n)| n % 3 == 0).collect_vec(); @@ -2088,8 +2088,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..3))).group_by(|&n| n % 2); /// let res = s.flat_map(|(_key, n)| vec![n, n]).collect_vec(); @@ -2116,8 +2116,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))).group_by(|&n| n % 2); /// s.inspect(|(key, n)| println!("Item: {} has key {}", n, key)).for_each(std::mem::drop); @@ -2154,8 +2154,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))).group_by(|&n| n % 2); /// let res = s @@ -2199,8 +2199,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))).group_by(|&n| n % 2); /// let res = s @@ -2232,8 +2232,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))).group_by(|&n| n % 2); /// let res = s.map(|(_key, n)| 10 * n).collect_vec(); @@ -2323,8 +2323,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let stream = env.stream(IteratorSource::new((0..4))).group_by(|&n| n % 2); /// let res = stream.unkey().collect_vec(); @@ -2345,8 +2345,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let stream = env.stream(IteratorSource::new((0..4))).group_by(|&n| n % 2); /// let res = stream.drop_key().collect_vec(); @@ -2366,8 +2366,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))).group_by(|&n| n % 2); /// s.for_each(|(key, n)| println!("Item: {} has key {}", n, key)); @@ -2426,8 +2426,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s1 = env.stream(IteratorSource::new((0..3))).group_by(|&n| n % 2); /// let s2 = env.stream(IteratorSource::new((3..5))).group_by(|&n| n % 2); @@ -2471,8 +2471,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s.shuffle(); @@ -2494,8 +2494,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10u32))); /// let rx = s.collect_channel(); @@ -2521,8 +2521,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..10u32))); /// let rx = s.collect_channel(); @@ -2552,8 +2552,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..3))).group_by(|&n| n % 2); /// let res = s.collect_vec(); @@ -2581,8 +2581,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..3))).group_by(|&n| n % 2); /// let res = s.collect_vec(); @@ -2614,8 +2614,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env /// .stream(IteratorSource::new(vec![ diff --git a/src/operator/source/async_stream.rs b/src/operator/source/async_stream.rs index f15e658e..81201a77 100644 --- a/src/operator/source/async_stream.rs +++ b/src/operator/source/async_stream.rs @@ -48,8 +48,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::AsyncStreamSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::AsyncStreamSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let stream = futures::stream::iter(0..10u32); /// let source = AsyncStreamSource::new(stream); diff --git a/src/operator/source/channel.rs b/src/operator/source/channel.rs index 508c546d..bbcf43c8 100644 --- a/src/operator/source/channel.rs +++ b/src/operator/source/channel.rs @@ -39,8 +39,8 @@ impl ChannelSource { /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::ChannelSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::ChannelSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let (tx_channel, source) = ChannelSource::new(4); /// let R = env.stream(source); diff --git a/src/operator/source/csv.rs b/src/operator/source/csv.rs index c6a3ab98..131edf49 100644 --- a/src/operator/source/csv.rs +++ b/src/operator/source/csv.rs @@ -126,8 +126,8 @@ impl Deserialize<'a>> CsvSource { /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::CsvSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::CsvSource; /// # use serde::{Deserialize, Serialize}; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// #[derive(Clone, Deserialize, Serialize)] diff --git a/src/operator/source/file.rs b/src/operator/source/file.rs index 231d0d50..1019b36e 100644 --- a/src/operator/source/file.rs +++ b/src/operator/source/file.rs @@ -46,8 +46,8 @@ impl FileSource { /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::FileSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::FileSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let source = FileSource::new("/datasets/huge.txt"); /// let s = env.stream(source); diff --git a/src/operator/source/iterator.rs b/src/operator/source/iterator.rs index 3b42eb10..7c1972ed 100644 --- a/src/operator/source/iterator.rs +++ b/src/operator/source/iterator.rs @@ -46,8 +46,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let source = IteratorSource::new((0..5)); /// let s = env.stream(source); diff --git a/src/operator/source/parallel_iterator.rs b/src/operator/source/parallel_iterator.rs index ed634264..68b89a9e 100644 --- a/src/operator/source/parallel_iterator.rs +++ b/src/operator/source/parallel_iterator.rs @@ -205,7 +205,7 @@ impl crate::StreamEnvironment { /// Convenience method, creates a `ParallelIteratorSource` and makes a stream using `StreamEnvironment::stream` /// # Example: /// ``` - /// use noir::prelude::*; + /// use noir_compute::prelude::*; /// /// let mut env = StreamEnvironment::default(); /// @@ -255,8 +255,8 @@ where /// ## Example /// /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::ParallelIteratorSource; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::ParallelIteratorSource; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// // generate the numbers from 0 to 99 using multiple replicas /// let n = 100; diff --git a/src/operator/window/aggr/fold.rs b/src/operator/window/aggr/fold.rs index f399bee8..c201e121 100644 --- a/src/operator/window/aggr/fold.rs +++ b/src/operator/window/aggr/fold.rs @@ -106,9 +106,9 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// # use noir::operator::window::CountWindow; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// # use noir_compute::operator::window::CountWindow; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5))); /// let res = s diff --git a/src/operator/window/mod.rs b/src/operator/window/mod.rs index 17609082..099be21d 100644 --- a/src/operator/window/mod.rs +++ b/src/operator/window/mod.rs @@ -291,9 +291,9 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// # use noir::operator::window::CountWindow; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// # use noir_compute::operator::window::CountWindow; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..9))); /// let res = s @@ -334,9 +334,9 @@ where /// /// ## Example /// ``` - /// # use noir::{StreamEnvironment, EnvironmentConfig}; - /// # use noir::operator::source::IteratorSource; - /// # use noir::operator::window::CountWindow; + /// # use noir_compute::{StreamEnvironment, EnvironmentConfig}; + /// # use noir_compute::operator::source::IteratorSource; + /// # use noir_compute::operator::window::CountWindow; /// # let mut env = StreamEnvironment::new(EnvironmentConfig::local(1)); /// let s = env.stream(IteratorSource::new((0..5usize))); /// let res = s diff --git a/tests/aggregators.rs b/tests/aggregators.rs index 2b6ee8fd..572dd07c 100644 --- a/tests/aggregators.rs +++ b/tests/aggregators.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/broadcast.rs b/tests/broadcast.rs index b4a84c7e..3fbcf16c 100644 --- a/tests/broadcast.rs +++ b/tests/broadcast.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/filter.rs b/tests/filter.rs index 5d9ea0f8..1fa34912 100644 --- a/tests/filter.rs +++ b/tests/filter.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/filter_map.rs b/tests/filter_map.rs index 4d0bf8a4..89bb176e 100644 --- a/tests/filter_map.rs +++ b/tests/filter_map.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/flatten.rs b/tests/flatten.rs index e242c641..652f4253 100644 --- a/tests/flatten.rs +++ b/tests/flatten.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/fold.rs b/tests/fold.rs index 5ee11ca0..e4774cc1 100644 --- a/tests/fold.rs +++ b/tests/fold.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/group_by.rs b/tests/group_by.rs index abdff22a..7167545b 100644 --- a/tests/group_by.rs +++ b/tests/group_by.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/interval_join.rs b/tests/interval_join.rs index f29e9afc..42b86783 100644 --- a/tests/interval_join.rs +++ b/tests/interval_join.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/iteration/iterate.rs b/tests/iteration/iterate.rs index 6b0b4cbe..942c4859 100644 --- a/tests/iteration/iterate.rs +++ b/tests/iteration/iterate.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use super::utils::TestHelper; diff --git a/tests/iteration/replay.rs b/tests/iteration/replay.rs index 8c91349e..d4b216e2 100644 --- a/tests/iteration/replay.rs +++ b/tests/iteration/replay.rs @@ -1,5 +1,5 @@ -use noir::operator::sink::StreamOutput; -use noir::operator::source::IteratorSource; +use noir_compute::operator::sink::StreamOutput; +use noir_compute::operator::source::IteratorSource; use super::utils::TestHelper; diff --git a/tests/join.rs b/tests/join.rs index d845d769..5e84828d 100644 --- a/tests/join.rs +++ b/tests/join.rs @@ -5,8 +5,8 @@ use std::time::Duration; use itertools::Itertools; -use noir::operator::source::IteratorSource; -use noir::BatchMode; +use noir_compute::operator::source::IteratorSource; +use noir_compute::BatchMode; use utils::TestHelper; mod utils; diff --git a/tests/key_by.rs b/tests/key_by.rs index 613e05e6..2c4b2d6a 100644 --- a/tests/key_by.rs +++ b/tests/key_by.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/keyed_fold.rs b/tests/keyed_fold.rs index 3e282505..989fb22a 100644 --- a/tests/keyed_fold.rs +++ b/tests/keyed_fold.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/keyed_reduce.rs b/tests/keyed_reduce.rs index f0b2e5c5..a8a73f4d 100644 --- a/tests/keyed_reduce.rs +++ b/tests/keyed_reduce.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/map.rs b/tests/map.rs index 2208e91e..083a7f6b 100644 --- a/tests/map.rs +++ b/tests/map.rs @@ -2,7 +2,7 @@ use std::str::FromStr; use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/merge.rs b/tests/merge.rs index b4f5d6c1..cc9a8ef4 100644 --- a/tests/merge.rs +++ b/tests/merge.rs @@ -3,8 +3,8 @@ use std::sync::Arc; use itertools::Itertools; -use noir::operator::source::IteratorSource; -use noir::Replication; +use noir_compute::operator::source::IteratorSource; +use noir_compute::Replication; use utils::{TestHelper, WatermarkChecker}; mod utils; diff --git a/tests/parallel_iterator.rs b/tests/parallel_iterator.rs index fed7e460..8945e319 100644 --- a/tests/parallel_iterator.rs +++ b/tests/parallel_iterator.rs @@ -1,5 +1,5 @@ use itertools::Itertools; -use noir::operator::source::ParallelIteratorSource; +use noir_compute::operator::source::ParallelIteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/reduce.rs b/tests/reduce.rs index b8f80ad1..ddaffe20 100644 --- a/tests/reduce.rs +++ b/tests/reduce.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/rich_filter_map.rs b/tests/rich_filter_map.rs index 95d456f2..f4ebe9bf 100644 --- a/tests/rich_filter_map.rs +++ b/tests/rich_filter_map.rs @@ -1,4 +1,4 @@ -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/rich_flat_map.rs b/tests/rich_flat_map.rs index 39d36b84..76821555 100644 --- a/tests/rich_flat_map.rs +++ b/tests/rich_flat_map.rs @@ -1,6 +1,6 @@ use itertools::{repeat_n, Itertools}; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/rich_map.rs b/tests/rich_map.rs index 127b4c91..dd1c6b2c 100644 --- a/tests/rich_map.rs +++ b/tests/rich_map.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/shuffle.rs b/tests/shuffle.rs index 8a2d2795..48458496 100644 --- a/tests/shuffle.rs +++ b/tests/shuffle.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/split.rs b/tests/split.rs index 4d414203..2afb8ac2 100644 --- a/tests/split.rs +++ b/tests/split.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/unkey.rs b/tests/unkey.rs index f6b48d08..957c993b 100644 --- a/tests/unkey.rs +++ b/tests/unkey.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils; diff --git a/tests/utils.rs b/tests/utils.rs index 42ee3546..78812978 100644 --- a/tests/utils.rs +++ b/tests/utils.rs @@ -10,12 +10,12 @@ use std::time::Duration; use itertools::{process_results, Itertools}; -use noir::config::{ExecutionRuntime, RemoteHostConfig, RemoteRuntimeConfig}; -use noir::operator::{Data, Operator, StreamElement, Timestamp}; -use noir::structure::BlockStructure; -use noir::CoordUInt; -use noir::ExecutionMetadata; -use noir::{EnvironmentConfig, StreamEnvironment}; +use noir_compute::config::{ExecutionRuntime, RemoteHostConfig, RemoteRuntimeConfig}; +use noir_compute::operator::{Data, Operator, StreamElement, Timestamp}; +use noir_compute::structure::BlockStructure; +use noir_compute::CoordUInt; +use noir_compute::ExecutionMetadata; +use noir_compute::{EnvironmentConfig, StreamEnvironment}; /// Port from which the integration tests start allocating sockets for the remote runtime. const TEST_BASE_PORT: u16 = 17666; diff --git a/tests/window/aggregator.rs b/tests/window/aggregator.rs index 1062b72a..04295d12 100644 --- a/tests/window/aggregator.rs +++ b/tests/window/aggregator.rs @@ -1,7 +1,7 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; -use noir::operator::window::CountWindow; +use noir_compute::operator::source::IteratorSource; +use noir_compute::operator::window::CountWindow; use super::utils::TestHelper; diff --git a/tests/window/aggregator_keyed.rs b/tests/window/aggregator_keyed.rs index 6b6824ca..c50c0962 100644 --- a/tests/window/aggregator_keyed.rs +++ b/tests/window/aggregator_keyed.rs @@ -1,7 +1,7 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; -use noir::operator::window::CountWindow; +use noir_compute::operator::source::IteratorSource; +use noir_compute::operator::window::CountWindow; use super::utils::TestHelper; diff --git a/tests/window/event_time.rs b/tests/window/event_time.rs index 8373a3a7..4abdd5e0 100644 --- a/tests/window/event_time.rs +++ b/tests/window/event_time.rs @@ -1,5 +1,5 @@ -use noir::operator::source::IteratorSource; -use noir::operator::window::EventTimeWindow; +use noir_compute::operator::source::IteratorSource; +use noir_compute::operator::window::EventTimeWindow; use super::utils::TestHelper; diff --git a/tests/window/join.rs b/tests/window/join.rs index 97d3bfcc..77c76961 100644 --- a/tests/window/join.rs +++ b/tests/window/join.rs @@ -1,5 +1,5 @@ -use noir::operator::source::IteratorSource; -use noir::operator::window::EventTimeWindow; +use noir_compute::operator::source::IteratorSource; +use noir_compute::operator::window::EventTimeWindow; use super::utils::TestHelper; diff --git a/tests/window/processing_time.rs b/tests/window/processing_time.rs index 09e9f2e8..52ca2934 100644 --- a/tests/window/processing_time.rs +++ b/tests/window/processing_time.rs @@ -1,7 +1,7 @@ use std::time::Duration; -use noir::operator::source::IteratorSource; -use noir::operator::window::ProcessingTimeWindow; +use noir_compute::operator::source::IteratorSource; +use noir_compute::operator::window::ProcessingTimeWindow; use super::utils::TestHelper; diff --git a/tests/zip.rs b/tests/zip.rs index 20fb412f..6bc2311b 100644 --- a/tests/zip.rs +++ b/tests/zip.rs @@ -1,6 +1,6 @@ use itertools::Itertools; -use noir::operator::source::IteratorSource; +use noir_compute::operator::source::IteratorSource; use utils::TestHelper; mod utils;