From 5959779fd2d8416ddc4c08d10250e97ceec64f7f Mon Sep 17 00:00:00 2001
From: Erik Mackdanz <erikmack@gmail.com>
Date: Thu, 30 Nov 2023 12:28:08 -0600
Subject: [PATCH] sort by value in bucket

---
 src/main.rs | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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
-- 
2.52.0