pub trait AggregateRecorder {
// Required methods
fn store(&mut self, record: Record);
fn flush(&mut self, step: i64);
}
Expand description
Stores records, then aggregates them and writes to an output destination.
pub trait AggregateRecorder {
// Required methods
fn store(&mut self, record: Record);
fn flush(&mut self, step: i64);
}
Stores records, then aggregates them and writes to an output destination.