using streaming for the project

Author: angelip2303

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pregel-rs"
-version = "0.0.7"
+version = "0.0.8"
 authors = [ "Ángel Iglesias Préstamo <angel.iglesias.prestamo@gmail.com>" ]
 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 = []

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

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