From 4380291441344c99a99127d63b78eb6f7a18a42a Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Wed, 7 Apr 2021 22:24:47 +0200
Subject: [PATCH] up

---
 disk/src/agg.rs | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/disk/src/agg.rs b/disk/src/agg.rs
index 9dc3520..f9c2835 100644
--- a/disk/src/agg.rs
+++ b/disk/src/agg.rs
@@ -154,6 +154,12 @@ pub struct MinMaxAvgScalarBinBatch {
     avgs: Vec<f32>,
 }
 
+impl std::fmt::Debug for MinMaxAvgScalarBinBatch {
+    fn fmt(&self, fmt: &mut std::fmt::Formatter) -> std::fmt::Result {
+        write!(fmt, "MinMaxAvgScalarBinBatch  count {}", self.ts1s.len())
+    }
+}
+
 impl AggregatableXdim1Bin for MinMaxAvgScalarBinBatch {
     type Output = MinMaxAvgScalarBinBatch;
     fn into_agg(self) -> Self::Output {
@@ -458,6 +464,10 @@ async fn agg_x_dim_1_inner() {
         k
     })
     .into_binned_t()
+    .map(|k| {
+        info!("after T binning  {:?}", k.as_ref().unwrap());
+        k
+    })
     .for_each(|k| ready(()));
     fut1.await;
 }