Struct persist::indexed::columnar::ColumnarRecordsBuilder

pub struct ColumnarRecordsBuilder {
    len: usize,
    key_data: MutableBuffer<u8>,
    key_offsets: MutableBuffer<i32>,
    val_data: MutableBuffer<u8>,
    val_offsets: MutableBuffer<i32>,
    timestamps: MutableBuffer<u64>,
    diffs: MutableBuffer<i64>,
}

An abstraction to incrementally add ((Key, Value), Time, Diff) records in a columnar representation, and eventually get back a ColumnarRecords.

Fields

len: usize

key_data: MutableBuffer<u8>

key_offsets: MutableBuffer<i32>

val_data: MutableBuffer<u8>

val_offsets: MutableBuffer<i32>

timestamps: MutableBuffer<u64>

diffs: MutableBuffer<i64>

Implementations

impl ColumnarRecordsBuilder

pub fn len(&self) -> usize

The number of (potentially duplicated) ((Key, Val), Time, Diff) records stored in Self.

fn borrow<'a>(&'a self) -> ColumnarRecordsRef<'a>

Borrow Self as a ColumnarRecordsRef.

pub fn reserve(
    &mut self,
    additional: usize,
    key_size_guess: usize,
    val_size_guess: usize
)

Reserve space for additional more records, based on key_size_guess and val_size_guess.

The guesses for key and val sizes are best effort, and if they end up being too small, the underlying buffers will be resized.

pub fn can_fit(&self, key: &[u8], val: &[u8], limit: usize) -> bool

Returns if the given key_offsets+key_data or val_offsets+val_data fits in the limits imposed by ColumnarRecords.

Note that limit is always KEY_VAL_DATA_MAX_LEN in production. It’s only override-able here for testing.

pub fn push(&mut self, record: ((&[u8], &[u8]), u64, isize)) -> bool

Add a record to Self.

Returns whether the record was successfully added. A record will not a added if it exceeds the size limitations of ColumnarBatch. This method is atomic, if it fails, no partial data will have been added.

pub fn finish(self) -> ColumnarRecords

Finalize constructing a ColumnarRecords.

Trait Implementations

impl Debug for ColumnarRecordsBuilder

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

Formats the value using the given formatter.

impl Default for ColumnarRecordsBuilder

fn default() -> Self

Returns the “default value” for a type.