Struct mz_persist_client::batch::BatchBuffer

struct BatchBuffer {
    metrics: Arc<Metrics>,
    blob_target_size: usize,
    records_builder: ColumnarRecordsBuilder,
}

Fields

metrics: Arc<Metrics>

blob_target_size: usize

records_builder: ColumnarRecordsBuilder

Implementations

impl BatchBuffer

fn new(metrics: Arc<Metrics>, blob_target_size: usize) -> Self

fn push<T: Codec64, D: Codec64>( &mut self, key: &[u8], val: &[u8], ts: T, diff: D, ) -> Option<BlobTraceUpdates>

fn drain(&mut self) -> BlobTraceUpdates

Trait Implementations

impl Debug for BatchBuffer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.