From e86e20d5e9dbd16820cd29af2936749d9befaa9b Mon Sep 17 00:00:00 2001 From: Dominik Werder Date: Fri, 6 Jun 2025 14:57:24 +0200 Subject: [PATCH] Add init fn --- src/timebin.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/timebin.rs b/src/timebin.rs index ac7f384..35e0832 100644 --- a/src/timebin.rs +++ b/src/timebin.rs @@ -1,11 +1,11 @@ -use crate::apitypes::ToUserFacingApiType; -use crate::collect_s::CollectableDyn; -use crate::container::ByteEstimate; -use crate::merge::MergeableDyn; use crate::AsAnyMut; use crate::AsAnyRef; use crate::TypeName; use crate::WithLen; +use crate::apitypes::ToUserFacingApiType; +use crate::collect_s::CollectableDyn; +use crate::container::ByteEstimate; +use crate::merge::MergeableDyn; use netpod::BinnedRange; use netpod::BinnedRangeEnum; use netpod::TsNano; @@ -158,6 +158,7 @@ pub trait BinnedEventsTimeweightTrait: fmt::Debug + Send { } pub trait BinnedBinsTimeweightTrait: fmt::Debug + Send { + fn cnt_zero_enable(&mut self); fn ingest(&mut self, bins: &BinsBoxed) -> Result<(), BinningggError>; fn input_done_range_final(&mut self) -> Result<(), BinningggError>; fn input_done_range_open(&mut self) -> Result<(), BinningggError>;