From: Erik Mackdanz <erikmack@gmail.com>
Date: Thu, 30 Nov 2023 18:28:08 +0000 (-0600)
Subject: sort by value in bucket
X-Git-Url: https://git.humopery.space/?a=commitdiff_plain;h=5959779fd2d8416ddc4c08d10250e97ceec64f7f;p=polarsbop.git

sort by value in bucket
---

diff --git a/src/main.rs b/src/main.rs
index dee3961..312f263 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -177,8 +177,11 @@ async fn reduce_bucket(bucket: &str) -> Result<(),Box<dyn Error>> {
     // read partitions to DF
     let bucketdf =
 	LazyJsonLineReader::new_paths(Arc::new(filepaths))
-	.finish()?;
-    println!("bucketdf: {:?}",bucketdf.collect()?);
+	.finish()?
+	.sort_by_exprs([col("Value")],
+		       vec!(false),false,false)
+	.collect()?;
+    println!("bucketdf: {:?}",bucketdf);
 
 
     // todo: some aggregation on my bucket