From ca40f17e293e5a2f299a914a5b25eb0b599fc882 Mon Sep 17 00:00:00 2001 From: angelip2303 Date: Wed, 24 May 2023 19:02:04 +0200 Subject: [PATCH] using streaming for the project --- Cargo.toml | 4 ++-- README.md | 2 +- src/pregel.rs | 2 ++ 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index 26483d5..de8a47e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "pregel-rs" -version = "0.0.7" +version = "0.0.8" authors = [ "Ángel Iglesias Préstamo " ] description = "A Graph library written in Rust for implementing your own algorithms in a Pregel fashion" documentation = "https://docs.rs/crate/pregel-rs/latest" @@ -12,7 +12,7 @@ keywords = ["pregel", "graph", "pagerank", "polars", "algorithms"] categories = ["algorithms", "database", "mathematics", "science"] [dependencies] -polars = { version = "0.29.0", features = ["lazy"] } +polars = { version = "0.29.0", features = ["lazy", "streaming"] } [package.metadata.docs.rs] features = [] diff --git a/README.md b/README.md index f487ed4..19bdc77 100644 --- a/README.md +++ b/README.md @@ -63,7 +63,7 @@ of your project. You can add the following line to your `Cargo.toml` file: ```toml [dependencies] -pregel-rs = "0.0.7" +pregel-rs = "0.0.8" ``` 4. _Implement your graph algorithm_: Now you can start implementing your graph diff --git a/src/pregel.rs b/src/pregel.rs index adb331f..d60b340 100644 --- a/src/pregel.rs +++ b/src/pregel.rs @@ -817,6 +817,7 @@ impl<'a> Pregel<'a> { .to_owned() .alias(self.vertex_column.as_ref()), // initial message column name is set by the user ]) + .with_streaming(true) .collect()?; // After computing the super-step 0, we start the execution of the Pregel algorithm. This // execution is performed until all the nodes vote to halt, or the number of iterations is @@ -911,6 +912,7 @@ impl<'a> Pregel<'a> { col(Column::Id.as_ref()), col(Column::Id.as_ref()), ) + .with_streaming(true) .collect()?; iteration += 1; // increment the counter so we now which iteration is being executed