Struct StreamingDownsampler 

pub struct StreamingDownsampler { /* private fields */ }

Boundary-safe downsampling over a sequence of time-ordered batches.

Rows must arrive ascending by timestamp — which is what the query engine’s merge guarantees — so a bucket is complete as soon as a row belonging to a later bucket is seen. Buckets are emitted in order and exactly once.

Example

let mut ds = StreamingDownsampler::new("value", 60_000_000_000, AggFn::Avg)?;
let mut out = Vec::new();
for batch in batches() {
    out.extend(ds.push(&batch)?);
}
out.extend(ds.finish()?);

Implementations

impl StreamingDownsampler

pub fn new(value_column: &str, interval: i64, function: AggFn) -> Result<Self>

Create a downsampler for value_column over interval-wide buckets.

Errors

Returns an error if interval is not positive.

pub fn push(&mut self, batch: &RecordBatch) -> Result<Vec<RecordBatch>>

Fold one batch in, returning any batches of completed buckets.

Errors

Returns an error if the timestamp or value column is missing or has an unsupported type, or if a row arrives out of timestamp order.

pub fn finish(self) -> Result<Vec<RecordBatch>>

Close the final bucket and return any remaining output.

Errors

Returns an error if the output batch cannot be built.