sort by value in bucket

diff --git a/src/main.rs b/src/main.rs
index dee3961ace8df7f5ff12f4258e0c6dd6f47dcf13..312f2632c4e1f1a452b4c7755c894c6ea053b1ee 100644 (file)
--- 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