attempt streaming

diff --git a/README b/README
index 21bb6fa724a88b8b0a3fadfb72e390165c804014..4f12d96c0607671479f9d8d844562562d63c16f0 100644 (file)
--- a/README
+++ b/README
@@ -1,2 +1,3 @@
-cargo build && ./scripts/paraexport
+. ~/var/source-for-polars-test.sh
+cargo build && time ./scripts/paraexport
 ls out/

diff --git a/src/main.rs b/src/main.rs
index cec9664fbd0c0f0c06024aedf6ed2577c940679b..f028e12b3a4a5fb63176c4dd66be8e98867963d3 100644 (file)
--- a/src/main.rs
+++ b/src/main.rs
@@ -73,6 +73,7 @@ async fn main() -> Result<(),PolarsError> {
        .rename(["2022"],["Value"])
        .sort_by_exprs([col("Country Name"),col("Indicator Name")],
                       vec!(false,false),false,false)
+       .with_streaming(true)
        .collect()?;
 
     // some console output