Struct ColumnarMemtable 

pub struct ColumnarMemtable { /* private fields */ }

In-memory columnar buffer that accumulates INSERTs.

Each column is stored as a typed vector. The memtable flushes to a compressed segment when the row count reaches the threshold.

Implementations

impl ColumnarMemtable

pub fn new(schema: &ColumnarSchema) -> Self

Create a new empty memtable for the given schema.

pub fn with_threshold(schema: &ColumnarSchema, flush_threshold: usize) -> Self

Create with a custom flush threshold.

pub fn append_row(&mut self, values: &[Value]) -> Result<(), ColumnarError>

Append a row of values. Validates types and nullability.

pub fn row_count(&self) -> usize

Number of rows currently buffered.

pub fn should_flush(&self) -> bool

Whether the memtable has reached its flush threshold.

pub fn is_empty(&self) -> bool

Whether the memtable is empty.

pub fn schema(&self) -> &ColumnarSchema

Access the schema.

pub fn columns(&self) -> &[ColumnData]

Access the raw column data (for the segment writer).

pub fn drain(&mut self) -> (ColumnarSchema, Vec<ColumnData>, usize)

Drain the memtable: return all column data and reset to empty.