Rename to noir_compute 🥹

deib-polimi · Dec 15, 2023 · aaae20c · aaae20c
1 parent 44667ac
commit aaae20c
Show file tree

Hide file tree

Showing 80 changed files with 280 additions and 286 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git 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.[email protected]>",
+    "Luca De Martini <luca.[email protected]>",
     "Edoardo Morassutto <[email protected]>",
     "Marco Donadoni <[email protected]>"
 ]

diff --git 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<String> {
 
 
 ```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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -35,15 +35,15 @@ 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);
 /// ```
 ///
 /// ## 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
@@ -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<String> {
 
 
 ```no_run
-use noir::prelude::*;
+use noir_compute::prelude::*;
 
 fn main() {
     // Convenience method to parse deployment config from CLI arguments